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.