Skip to main content

move_by_taskmap

Move tasks by matching from a task_name: queue mapping.

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

Move tasks by matching from a task_name: queue mapping.

Parameters​

NameTypeDescription
mapdictA dictionary mapping task names to the destination Queue objects where they should be moved.
**kwargsdictAdditional keyword arguments passed directly to the underlying move function, such as transform or filter functions.

Returns​

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