#NEWLINE# def test_fault_midstream( ) : #NEWLINE# #INDENT# 'Test if a previous upload fault is detected in calling .put.\n\n    This case is seen while pipelining many uploads in excess of the\n    maximum concurrency.\n\n    NB: This test is critical as to prevent failed uploads from\n    failing to notify a caller that the entire backup is incomplete.\n    ' #NEWLINE# pool = make_pool ( 1 , 1 ) #NEWLINE# tpart = FakeTarPartition ( 1 , explosive = Explosion ( 'Boom' ) ) #NEWLINE# pool . put ( pool ) #NEWLINE# tpart = FakeTarPartition ( 1 ) #NEWLINE# with pytest . raises ( Explosion ) : #NEWLINE# #INDENT# pool . put ( tpart )