This document describes an older version of Celery (2.5). For the latest stable version please go here.

celery.apps.worker

class celery.apps.worker.Worker(hostname=None, discard=False, embed_clockservice=False, queues=None, include=None, app=None, pidfile=None, autoscale=None, autoreload=False, **kwargs)
class WorkController(loglevel=None, hostname=None, logger=None, ready_callback=<function noop at 0x1cd7668>, queues=None, app=None, **kwargs)

Unmanaged worker instance.

CLOSE = 2
RUN = 1
TERMINATE = 3
autoreloader_cls = None
autoscaler_cls = None
concurrency = None
consumer_cls = None
disable_rate_limits = None
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.

Worker.die(msg, exitcode=1)
Worker.extra_info()
Worker.inherit_confopts = (<class 'celery.worker.WorkController'>,)
Worker.init_loader()
Worker.init_queues()
Worker.install_platform_tweaks(worker)

Install platform specific tweaks and workarounds.

Worker.loglevel = None
Worker.on_consumer_ready(consumer)
Worker.osx_proxy_detection_workaround()

See http://github.com/celery/celery/issues#issue/161

Worker.purge_messages()
Worker.redirect_stdouts = None
Worker.redirect_stdouts_level = None
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.get_process_name()
celery.apps.worker.install_HUP_not_supported_handler(worker)
celery.apps.worker.install_cry_handler(logger)
celery.apps.worker.install_rdb_handler(envvar='CELERY_RDBSIG')
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)
celery.apps.worker.install_worker_term_hard_handler(worker)

Previous topic

celery.events.state

Next topic

celery.apps.beat

This Page