Download 2.5-archived PDF

Celery Documentation, Release 2.5.5
eta_scheduler_cls = None
eta_scheduler_precision = None
force_execv = None
logfile = None
loglevel = 40
max_tasks_per_child = None
mediator_cls = None
on_timer_error(einfo)
on_timer_tick(delay)
pool_cls = None
pool_putlocks = None
prefetch_multiplier = None
process_task(request)
Process task by sending it to the pool of workers.
reload(modules=None, reload=False, reloader=None)
schedule_filename = None
scheduler_cls = None
send_events = None
start()
Starts the workers main loop.
state
state_db = None
stop(in_sighandler=False)
Graceful shutdown of the worker server.
task_soft_time_limit = None
task_time_limit = None
terminate(in_sighandler=False)
Not so graceful shutdown of the worker server.
13.6.3 celery.worker.consumer
• celery.worker.consumer
celery.worker.consumer
This module contains the component responsible for consuming messages from the broker, processing the messages
and keeping the broker connections up and running.
copyright
13.6. Internal Module Reference
327