Download 2.3-archived PDF

Celery Documentation, Release 2.3.5
exception TaskPool.Pool.SoftTimeLimitExceeded
The soft time limit has been exceeded. This exception is raised to give the task a chance to clean
up.
class TaskPool.Pool.Supervisor(pool)
body()
class TaskPool.Pool.TaskHandler(taskqueue, put, outqueue, pool)
body()
class TaskPool.Pool.TimeoutHandler(processes, cache, t_soft, t_hard)
body()
TaskPool.Pool.apply(func, args=(), kwds={})
Equivalent of apply() builtin
TaskPool.Pool.apply_async(func,
args=(),
kwds={},
callback=None,
accept_callback=None,
timeout_callback=None,
waitforslot=False, error_callback=None, soft_timeout=None,
timeout=None)
Asynchronous equivalent of apply() builtin.
Callback is called when the functions return value is ready. The accept callback is called when the
job is accepted to be executed.
Simplified the flow is like this:
>>> if accept_callback:
...
accept_callback()
>>> retval = func(*args, **kwds)
>>> if callback:
...
callback(retval)
TaskPool.Pool.close()
TaskPool.Pool.grow(n=1)
TaskPool.Pool.imap(func, iterable, chunksize=1)
Equivalent of itertools.imap() – can be MUCH slower than Pool.map()
TaskPool.Pool.imap_unordered(func, iterable, chunksize=1)
Like imap() method but ordering of results is arbitrary
TaskPool.Pool.join()
TaskPool.Pool.map(func, iterable, chunksize=None)
Equivalent of map() builtin
TaskPool.Pool.map_async(func, iterable, chunksize=None, callback=None)
Asynchronous equivalent of map() builtin
TaskPool.Pool.shrink(n=1)
TaskPool.Pool.terminate()
TaskPool.grow(n=1)
11.5. Internal Module Reference
283