#NEWLINE# def test_setRetryTask( self ) : #NEWLINE# #INDENT# payload = { #NEWLINE# #INDENT# 'dict' : { #NEWLINE# #INDENT# 'a' : 1 , #NEWLINE# 'b' : 2 , #NEWLINE# #UNINDENT# } , #NEWLINE# 'var' : 'alpha' , #NEWLINE# 'list' : [ 'apples' , 'oranges' , 'bananas' ] , #NEWLINE# #UNINDENT# } #NEWLINE# resp = self . worker . queue ( code_name = self . code_name , payload = payload ) #NEWLINE# task_id = resp . id #NEWLINE# res = self . worker . retry ( task_id , 10 ) #NEWLINE# self . assertEqual ( task_id [ 'msg' ] , 'Queued up' )