EVECelery.EVECeleryBeatScheduler#

Module Contents#

Classes#

EVECeleryBeatScheduler

Celery beat scheduler for periodic tasks.
class EVECelery.EVECeleryBeatScheduler.EVECeleryBeatScheduler(broker_user: str | None = None, broker_password: str | None = None, broker_host: str | None = None, broker_port: int | None = None, broker_vhost: str | None = None, result_user: str | None = None, result_password: str | None = None, result_host: str | None = None, result_port: int | None = None, result_db: int | None = None, queue_prefix: str = 'EVECelery.', worker_log_level: str | None = 'ERROR', connection_check: bool = False)#

Bases: EVECelery.EVECeleryWorker.EVECeleryWorker

Celery beat scheduler for periodic tasks.

Parameters:

  • broker_user (Optional[str]) –

  • broker_password (Optional[str]) –

  • broker_host (Optional[str]) –

  • broker_port (Optional[int]) –

  • broker_vhost (Optional[str]) –

  • result_user (Optional[str]) –

  • result_password (Optional[str]) –

  • result_host (Optional[str]) –

  • result_port (Optional[int]) –

  • result_db (Optional[int]) –

  • queue_prefix (str) –

  • worker_log_level (Optional[str]) –

  • connection_check (bool) –

schedule_task(schedule_name: str, schedule_config: dict)#

Schedule a task to run at intervals. The passed in schedule object is a dictionary following the format and fields described here: https://docs.celeryproject.org/en/stable/userguide/periodic-tasks.html#available-fields

Parameters:
Returns:

None

start()#

Starts the Celery app and beings processing messages in the queues.

Returns:

None