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

Name	Type	Description
map	dict	A dictionary mapping task names to the destination Queue objects where they should be moved.
**kwargs	dict	Additional keyword arguments passed directly to the underlying move function, such as transform or filter functions.

Returns

Type	Description
Any	The result of the underlying move operation, typically indicating the number of tasks successfully relocated.