signals.py 740 B

12345678910111213141516171819
  1. from celery.utils.dispatch import Signal
  2. task_sent = Signal(providing_args=["task_id", "task",
  3. "args", "kwargs",
  4. "eta", "taskset"])
  5. task_prerun = Signal(providing_args=["task_id", "task",
  6. "args", "kwargs"])
  7. task_postrun = Signal(providing_args=["task_id", "task",
  8. "args", "kwargs", "retval"])
  9. worker_init = Signal(providing_args=[])
  10. worker_process_init = Signal(providing_args=[])
  11. worker_ready = Signal(providing_args=[])
  12. worker_shutdown = Signal(providing_args=[])
  13. setup_logging = Signal(providing_args=["loglevel", "logfile",
  14. "format", "colorize"])