Skip to main content

move_by_idmap

Move tasks by matching from a task_id: queue mapping.

def move_by_idmap(
map: dict,
**kwargs: dict
) - > Any

Move tasks by matching from a task_id: queue mapping. Where queue is a queue to move the task to.

Parameters

NameTypeDescription
mapdictA dictionary mapping specific task correlation IDs to their target Queue objects.
**kwargsdictAdditional keyword arguments passed to the underlying move function, such as source queue names or transformation callbacks.

Returns

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