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.extra_info()
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)

Previous topic

celery.events.state

Next topic

celery.apps.beat

This Page