Skip to main content

add_chunk_task

Defines and registers the 'celery.chunks' task on the provided Celery application instance, enabling the distribution of task chunks across workers.

def add_chunk_task(
app: Celery
) - > function

Registers the 'celery.chunks' task on the provided Celery application instance during the finalization phase.

Parameters

NameTypeDescription
appCeleryThe Celery application instance where the chunking task will be registered.

Returns

TypeDescription
functionThe registered 'celery.chunks' task function which executes chunked task logic.