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