add_accumulate_task
Task used by Task.replace when replacing task with group.
def add_accumulate_task(
app: Celery application instance
) - > function
Task used by Task.replace when replacing task with group.
Parameters
| Name | Type | Description |
|---|---|---|
| app | Celery application instance | The Celery application instance where the accumulate task will be registered. |
Returns
| Type | Description |
|---|---|
function | The Celery task function named 'celery.accumulate' which extracts specific arguments based on an index. |