This document is for Celery's development version, which can be significantly different from previous releases. Get old docs here: 2.5.

celery.apps.worker

class celery.apps.worker.Worker(hostname=None, purge=False, beat=False, queues=None, include=None, app=None, pidfile=None, autoscale=None, autoreload=False, no_execv=False, **kwargs)

class WorkController(loglevel=None, hostname=None, ready_callback=<function noop at 0x101b3fde8>, queues=None, app=None, **kwargs)

Unmanaged worker instance.

CLOSE = 2

RUN = 1

TERMINATE = 3

app = None

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

pool_cls = None

pool_putlocks = None

prefetch_multiplier = None

process_task(req)

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_lost_wait = None

Worker.app = None

Worker.extra_info()

Worker.inherit_confopts = (<class 'celery.worker.WorkController'>,)

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/ask/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)

celery.apps.worker.install_HUP_not_supported_handler(worker, sig='SIGHUP')

celery.apps.worker.install_cry_handler()

celery.apps.worker.install_rdb_handler(envvar='CELERY_RDBSIG', sig='SIGUSR2')

celery.apps.worker.install_worker_restart_handler(worker, sig='SIGHUP')

celery.apps.worker.on_SIGINT(worker)