replace_with_chain

Replaces the current task with a Celery chain that executes identity tasks and links a redis_echo signature, optionally passing a custom message to the linked task.

def replace_with_chain(
    self: celery.app.task.Task,
    *args: Any,
    link_msg: string = null
) - > celery.result.AsyncResult

Replaces the current task with a chain of identity tasks and attaches an optional linked callback.

Parameters

Name	Type	Description
self	celery.app.task.Task	The current task instance being replaced.
*args	Any	Positional arguments passed to the initial identity task in the chain.
link_msg	string = null	An optional message to be passed to the redis_echo callback; if provided, the callback becomes immutable.

Returns

Type	Description
celery.result.AsyncResult	The result of the replacement chain execution.