#NEWLINE# def test_party_session_failure( self ) : #NEWLINE# #INDENT# partitioner = self . client . SetPartitioner ( self . path , set = ( 1 , 2 , 3 ) , time_boundary = 0.2 ) #NEWLINE# partitioner . wait_for_acquire ( 14 ) #NEWLINE# eq_ ( partitioner . state , PartitionState . ACQUIRED ) #NEWLINE# partitioner . _fail_out ( ) #NEWLINE# partitioner . release_set ( ) #NEWLINE# self . assertTrue ( self . failed )