#NEWLINE# def test_resubmit_inflight( self ) : #NEWLINE# #INDENT# 'ensure ValueError on resubmit of inflight task' #NEWLINE# v = self . client . load_balanced_view ( ) #NEWLINE# ar = v . apply_async ( time . sleep , 1 ) #NEWLINE# time . sleep ( 0.2 ) #NEWLINE# self . assertRaisesRemote ( ValueError , self . client . resubmit , v . msg_ids ) #NEWLINE# ar . get ( 2 )