migrate_tasks

Migrate tasks from one broker to another.

def migrate_tasks(
    source: Any,
    dest: Any,
    migrate: Callable = migrate_task,
    app: Celery = None,
    queues: List[str]|Dict = None,
    **kwargs: Any
) - > Any

Migrate tasks from one broker to another.

Parameters

Name	Type	Description
source	Any	The source broker connection or URL from which tasks will be consumed.
dest	Any	The destination broker connection or URL where tasks will be republished.
migrate	Callable = migrate_task	The function responsible for performing the individual task migration logic.
app	Celery = None	The Celery application instance to use; defaults to the current app if not provided.
queues	`List[str]	Dict` = None
**kwargs	Any	Additional configuration arguments passed to the underlying start_filter function.

Returns

Type	Description
Any	The result of the start_filter operation, typically initiating the task transfer process.