12345678910111213141516171819 |
- from celery.utils.dispatch import Signal
- task_sent = Signal(providing_args=["task_id", "task",
- "args", "kwargs",
- "eta", "taskset"])
- task_prerun = Signal(providing_args=["task_id", "task",
- "args", "kwargs"])
- task_postrun = Signal(providing_args=["task_id", "task",
- "args", "kwargs", "retval"])
- worker_init = Signal(providing_args=[])
- worker_process_init = Signal(providing_args=[])
- worker_ready = Signal(providing_args=[])
- worker_shutdown = Signal(providing_args=[])
- setup_logging = Signal(providing_args=["loglevel", "logfile",
- "format", "colorize"])
|