#NEWLINE# def route_for_task( self , task_name , * args , **kwargs ) : #NEWLINE# #INDENT# task = app . tasks . get ( task_name ) #NEWLINE# if getattr ( kwargs , 'is_heavy_task' , False ) : #NEWLINE# #INDENT# return { #NEWLINE# #INDENT# 'queue' : 'heavy' , #NEWLINE# #UNINDENT# } #NEWLINE# #UNINDENT# return None