Increment value. celery.datastructures.consume_queue(queue) Iterator yielding all immediately available items in a Queue.Queue. The iterator stops as soon as the queue raises Queue.Empty. Example >>> celery.log 8.6.25 Multiprocessing Worker - celery.worker celery.utils.chunks(it, n) Split an iterator into chunks with n elements each. Examples # n == 2 >>> x = chunks(iter([0, 1, 2, 3, 4, 5, 6, ("George", "Constanza", "NYC", "Earth") celery.utils.repeatlast(it) Iterate over all elements in the iterator, and when its exhausted yield the last value infinitely. celery.utils.retry_over_time(fun, catch

Increment value. celery.datastructures.consume_queue(queue) Iterator yielding all immediately available items in a Queue.Queue. The iterator stops as soon as the queue raises Queue.Empty. Example >>> Module Reference » Multiprocessing Worker - celery.worker celery.utils.chunks(it, n) Split an iterator into chunks with n elements each. Examples # n == 2 >>> x = chunks(iter([0, 1, 2, 3, 4, 5, 6, ("George", "Constanza", "NYC", "Earth") celery.utils.repeatlast(it) Iterate over all elements in the iterator, and when its exhausted yield the last value infinitely. celery.utils.retry_over_time(fun, catch

Increment value. celery.datastructures.consume_queue(queue) Iterator yielding all immediately available items in a Queue.Queue. The iterator stops as soon as the queue raises Queue.Empty. Example >>> Session - celery.db.session 8.6.32 Utilities - celery.utils celery.utils.chunks(it, n) Split an iterator into chunks with n elements each. Examples # n == 2 >>> x = chunks(iter([0, 1, 2, 3, 4, 5, 6, __repr__(), __cmp__(). evaluate() celery.utils.repeatlast(it) Iterate over all elements in the iterator, and when its exhausted yield the last value infinitely. celery.utils.retry_over_time(fun, catch

The exception if any of the tasks raised an exception. itersubtasks() Taskset subtask iterator. Returns an iterator for iterating over the tasksets AsyncResult objects. join(timeout=None, propagate=True) from the bucket celery.datastructures.consume_queue(queue) Iterator yielding all immediately available items in a Queue.Queue. The iterator stops as soon as the queue raises Queue.Empty. Example >>> abbr(S, max, ellipsis=’...’) celery.utils.abbrtask(S, max) celery.utils.chunks(it, n) Split an iterator into chunks with n elements each. Examples # n == 2 >>> x = chunks(iter([0, 1, 2, 3, 4, 5, 6,

Increment value. celery.datastructures.consume_queue(queue) Iterator yielding all immediately available items in a Queue.Queue. The iterator stops as soon as the queue raises Queue.Empty. Example >>> Internals » Internal Module Reference » Utilities - celery.utils celery.utils.chunks(it, n) Split an iterator into chunks with n elements each. Examples # n == 2 >>> x = chunks(iter([0, 1, 2, 3, 4, 5, 6, __repr__(), __cmp__(). evaluate() celery.utils.repeatlast(it) Iterate over all elements in the iterator, and when its exhausted yield the last value infinitely. celery.utils.retry_over_time(fun, catch

exception if any of the tasks raised an exception. itersubtasks() Taskset subtask iterator. Returns: an iterator for iterating over the tasksets AsyncResult objects. join(timeout=None, propagate=True) from the bucket celery.datastructures.consume_queue(queue) Iterator yielding all immediately available items in a Queue.Queue. The iterator stops as soon as the queue raises Queue.Empty. Example >>> abbr(S, max, ellipsis='...') celery.utils.abbrtask(S, max) celery.utils.chunks(it, n) Split an iterator into chunks with n elements each. Examples # n == 2 >>> x = chunks(iter([0, 1, 2, 3, 4, 5, 6,

property children collect(intermediate=False, **kwargs)[source] Collect results as they return. Iterator, like get() will wait for the task to complete, but will also follow AsyncResult and ResultSet returned restore(id, backend=None, app=None)[source] Restore previously saved group result. results = None List/iterator of results in the group save(backend=None)[source] Save group-result for later retrieval using Base class for certificate stores. add_cert(cert)[source] itercerts()[source] Return certificate iterator. class celery.security.certificate.Certificate(cert)[source] X.509 certificate. get_id()[source]

property children collect(intermediate=False, **kwargs)[source] Collect results as they return. Iterator, like get() will wait for the task to complete, but will also follow AsyncResult and ResultSet returned restore(id, backend=None, app=None)[source] Restore previously saved group result. results = None List/iterator of results in the group save(backend=None)[source] Save group-result for later retrieval using Base class for certificate stores. add_cert(cert)[source] itercerts()[source] Return certificate iterator. class celery.security.certificate.Certificate(cert)[source] X.509 certificate. get_id()[source]

property children collect(intermediate=False, **kwargs)[source] Collect results as they return. Iterator, like get() will wait for the task to complete, but will also follow AsyncResult and ResultSet returned restore(id, backend=None, app=None)[source] Restore previously saved group result. results = None List/iterator of results in the group save(backend=None)[source] Save group-result for later retrieval using Base class for certificate stores. add_cert(cert)[source] itercerts()[source] Return certificate iterator. class celery.security.certificate.Certificate(cert)[source] X.509 certificate. get_id()[source]

property children collect(intermediate=False, **kwargs)[source] Collect results as they return. Iterator, like get() will wait for the task to complete, but will also follow AsyncResult and ResultSet returned restore(id, backend=None, app=None)[source] Restore previously saved group result. results = None List/iterator of results in the group save(backend=None)[source] Save group-result for later retrieval using Base class for certificate stores. add_cert(cert)[source] itercerts()[source] Return certificate iterator. class celery.security.certificate.Certificate(cert)[source] X.509 certificate. get_id()[source]