def move_by_taskmap(map, **kwargs):
 def task_name_in_map(body, message):
  return map.get(body[u'task'])
 return move(task_name_in_map, **kwargs)

def move_by_taskmap ( map , ** kwargs ) : def task_name_in_map ( body , message ) : return map . get ( body [ u'task' ] ) return move ( task_name_in_map , ** kwargs )
move tasks by matching from a task_name: queue mapping .