Skip to main content

move_task_by_id

Find a task by id and move it to another queue.

def move_task_by_id(
task_id: str,
dest: str or kombu.Queue,
transform: Callable,
**kwargs: Any
) - > Any

Find a task by id and move it to another queue.

Parameters

NameTypeDescription
task_idstrThe unique identifier of the task to find and move.
deststr or kombu.QueueThe destination queue where the task should be relocated.
transformCallableOptional function to transform the return value (destination) of the filter function.
**kwargsAnyAdditional keyword arguments supported by the underlying move function, such as filtering or limit options.

Returns

TypeDescription
AnyThe result of the move operation, typically indicating the number of tasks successfully relocated.