Skip to main content

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​

NameTypeDescription
appCelery application instanceThe Celery application instance where the accumulate task will be registered.

Returns​

TypeDescription
functionThe Celery task function named 'celery.accumulate' which extracts specific arguments based on an index.