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
| Name | Type | Description |
|---|---|---|
| app | Celery | The Celery application instance where the chunking task will be registered. |
Returns
| Type | Description |
|---|---|
function | The registered 'celery.chunks' task function which executes chunked task logic. |