| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- # -*- coding: utf-8 -*-
- """
- celery.signals
- ~~~~~~~~~~~~~~
- See :ref:`signals`.
- :copyright: (c) 2009 - 2011 by Ask Solem.
- :license: BSD, see LICENSE for more details.
- """
- from __future__ import absolute_import
- from .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"])
- task_failure = Signal(providing_args=["task_id", "exception",
- "args", "kwargs", "traceback",
- "einfo"])
- 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"])
- after_setup_logger = Signal(providing_args=["logger", "loglevel", "logfile",
- "format", "colorize"])
- after_setup_task_logger = Signal(providing_args=["logger", "loglevel",
- "logfile", "format",
- "colorize"])
- beat_init = Signal(providing_args=[])
- beat_embedded_init = Signal(providing_args=[])
- eventlet_pool_started = Signal(providing_args=[])
- eventlet_pool_preshutdown = Signal(providing_args=[])
- eventlet_pool_postshutdown = Signal(providing_args=[])
- eventlet_pool_apply = Signal(providing_args=["target", "args", "kwargs"])
|
