(self, request_id, failure, duration)
Publish a CommandFailedEvent.
Publish a CommandFailedEvent.
Publish a CommandFailedEvent .
def _fail(self, request_id, failure, duration):
        """Publish a CommandFailedEvent."""
        self.listeners.publish_command_failure(
            duration, failure, self.name,
            request_id, self.sock_info.address, self.op_id)
def _fail ( self , request_id , failure , duration ) : self . listeners . publish_command_failure ( duration , failure , self . name , request_id , self . sock_info . address , self . op_id )