#NEWLINE# def test_retry_policy_says_ignore( self ) : #NEWLINE# #INDENT# session = self . make_session ( ) #NEWLINE# query = SimpleStatement ( 'INSERT INFO foo (a, b) VALUES (1, 2)' ) #NEWLINE# query . retry_policy = Mock ( ) #NEWLINE# query . retry_policy . on_unavailable . return_value = ( RetryPolicy . IGNORE , None ) #NEWLINE# message = QueryMessage ( query = query , consistency_level = ConsistencyLevel . ONE ) #NEWLINE# rf = ResponseFuture ( session , message , query , 1 ) #NEWLINE# rf . send_request ( ) #NEWLINE# result = Mock ( spec = UnavailableErrorMessage , info = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } ) #NEWLINE# rf . _set_result ( result ) #NEWLINE# self . assertFalse ( rf . result ( ) )