This document describes the current stable version of Celery (3.1). For development docs, go here.
celery.concurrency.base¶
celery.concurrency.base¶
TaskPool interface.
-
class
celery.concurrency.base.
BasePool
(limit=None, putlocks=True, forking_enable=True, callbacks_propagate=(), **options)[source]¶ -
CLOSE
= 2¶
-
RUN
= 1¶
-
TERMINATE
= 3¶
-
class
Timer
(schedule=None, on_error=None, on_tick=None, on_start=None, max_interval=None, **kwargs)¶ -
-
Schedule
¶ alias of
Timer
-
call_after
(*args, **kwargs)¶
-
call_at
(*args, **kwargs)¶
-
call_repeatedly
(*args, **kwargs)¶
-
cancel
(tref)¶
-
clear
()¶
-
empty
()¶
-
ensure_started
()¶
-
enter
(entry, eta, priority=None)¶
-
enter_after
(*args, **kwargs)¶
-
exit_after
(secs, priority=10)¶
-
next
()¶
-
on_tick
= None¶
-
queue
¶
-
run
()¶
-
running
= False¶
-
stop
()¶
-
-
active
¶
-
apply_async
(target, args=[], kwargs={}, **options)[source]¶ Equivalent of the
apply()
built-in function.Callbacks should optimally return as soon as possible since otherwise the thread which handles the result will get blocked.
-
info
¶
-
is_green
= False¶ set to true if pool uses greenlets.
-
num_processes
¶
-
signal_safe
= True¶ set to true if the pool can be shutdown from within a signal handler.
-
task_join_will_block
= True¶
-
uses_semaphore
= False¶ only used by multiprocessing pool
-