add_chord_task(app)[source] No longer used, but here for backwards compatibility. celery.app.builtins.add_chunk_task(app)[source] celery.app.builtins.add_group_task(app)[source] No longer used, but here for backwards add_chain_task() (in module celery.app.builtins) add_chord_task() (in module celery.app.builtins) add_chunk_task() (in module celery.app.builtins) add_compat() (celery.app.amqp.Queues method) add_consumer es)), result._set_length, )) return (item for chunk in result for item in chunk) def imap_unordered(self, func, iterable, chunksize=1, lo

add_chord_task(app)[source] No longer used, but here for backwards compatibility. celery.app.builtins.add_chunk_task(app)[source] celery.app.builtins.add_group_task(app)[source] No longer used, but here for backwards add_chain_task() (in module celery.app.builtins) add_chord_task() (in module celery.app.builtins) add_chunk_task() (in module celery.app.builtins) add_compat() (celery.app.amqp.Queues method) add_consumer es)), result._set_length, )) return (item for chunk in result for item in chunk) def imap_unordered(self, func, iterable, chunksize=1, lo

add_chord_task(app)[source] No longer used, but here for backwards compatibility. celery.app.builtins.add_chunk_task(app)[source] celery.app.builtins.add_group_task(app)[source] No longer used, but here for backwards add_chain_task() (in module celery.app.builtins) add_chord_task() (in module celery.app.builtins) add_chunk_task() (in module celery.app.builtins) add_compat() (celery.app.amqp.Queues method) add_consumer es)), result._set_length, )) return (item for chunk in result for item in chunk) def imap_unordered(self, func, iterable, chunksize=1, lo

add_chord_task(app)[source] No longer used, but here for backwards compatibility. celery.app.builtins.add_chunk_task(app)[source] celery.app.builtins.add_group_task(app)[source] No longer used, but here for backwards add_chain_task() (in module celery.app.builtins) add_chord_task() (in module celery.app.builtins) add_chunk_task() (in module celery.app.builtins) add_compat() (celery.app.amqp.Queues method) add_consumer es)), result._set_length, )) return (item for chunk in result for item in chunk) def imap_unordered(self, func, iterable, chunksize=1, lo

def __read__(fd, buf, size, read=os.read): # noqa chunk = read(fd, size) n = len(chunk) if n != 0: buf.write(chunk) return n readcanbuf = False # noqa def unpack_from(fmt s)), result._set_length, )) return (item for chunk in result for item in chunk) def imap_unordered(self, func, iterable, chunksize=1, lo es)), result._set_length, )) return (item for chunk in result for item in chunk) def apply_async(self, func, args=(), kwds={}, callback=None

def __read__(fd, buf, size, read=os.read): # noqa chunk = read(fd, size) n = len(chunk) if n != 0: buf.write(chunk) return n readcanbuf = False # noqa def unpack_from(fmt s)), result._set_length, )) return (item for chunk in result for item in chunk) def imap_unordered(self, func, iterable, chunksize=1, lo es)), result._set_length, )) return (item for chunk in result for item in chunk) def apply_async(self, func, args=(), kwds={}, callback=None