This document describes an older version of Celery (2.2).
For the latest stable version please
go here.
celery.apps.worker
-
class celery.apps.worker.Worker(concurrency=None, loglevel=None, logfile=None, hostname=None, discard=False, run_clockservice=False, schedule=None, task_time_limit=None, task_soft_time_limit=None, max_tasks_per_child=None, queues=None, events=False, db=None, include=None, app=None, pidfile=None, redirect_stdouts=None, redirect_stdouts_level=None, autoscale=None, scheduler_cls=None, pool=None, **kwargs)
-
class WorkController(concurrency=None, logfile=None, loglevel=None, send_events=None, hostname=None, ready_callback=<function noop at 0x2aed398>, embed_clockservice=False, pool_cls=None, consumer_cls=None, mediator_cls=None, eta_scheduler_cls=None, schedule_filename=None, task_time_limit=None, task_soft_time_limit=None, max_tasks_per_child=None, pool_putlocks=None, db=None, prefetch_multiplier=None, eta_scheduler_precision=None, disable_rate_limits=None, autoscale=None, autoscaler_cls=None, scheduler_cls=None, app=None)
Unmanaged worker instance.
-
CLOSE = 2
-
RUN = 1
-
TERMINATE = 3
-
concurrency = None
-
consumer = None
-
embed_clockservice = None
-
logfile = None
-
logger = None
-
loglevel = 40
-
mediator = None
-
on_timer_error(exc_info)
-
on_timer_tick(delay)
-
pool = None
-
process_task(request)
Process task by sending it to the pool of workers.
-
ready_queue = None
-
send_events = False
-
start()
Starts the workers main loop.
-
stop(in_sighandler=False)
Graceful shutdown of the worker server.
-
terminate(in_sighandler=False)
Not so graceful shutdown of the worker server.
-
Worker.die(msg, exitcode=1)
-
Worker.init_loader()
-
Worker.init_queues()
-
Worker.install_platform_tweaks(worker)
Install platform specific tweaks and workarounds.
-
Worker.on_consumer_ready(consumer)
-
Worker.osx_proxy_detection_workaround()
See http://github.com/ask/celery/issues#issue/161
-
Worker.purge_messages()
-
Worker.redirect_stdouts_to_logger()
-
Worker.run()
-
Worker.run_worker()
-
Worker.set_process_status(info)
-
Worker.startup_info()
-
Worker.tasklist(include_builtins=True)
-
Worker.worker_init()
-
celery.apps.worker.cpu_count()
-
celery.apps.worker.install_HUP_not_supported_handler(worker)
-
celery.apps.worker.install_cry_handler(logger)
-
celery.apps.worker.install_rdb_handler()
-
celery.apps.worker.install_worker_int_again_handler(worker)
-
celery.apps.worker.install_worker_int_handler(worker)
-
celery.apps.worker.install_worker_restart_handler(worker)
-
celery.apps.worker.install_worker_term_handler(worker)