This document describes Celery 2.4. For development docs, 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=None, 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>, 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
()¶
-
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
()¶
-
class
-
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)¶