'This is just a simple method that submits a statement with a payload, and validates
that the custom payload we submitted matches the one that we got back
@param statement The statement to execute
@param custom_payload The custom payload to submit with'

def execute_async_validate_custom_payload(self, statement, custom_payload):

    response_future = self.session.execute_async(statement, custom_payload=custom_payload)
    response_future.result()
    returned_custom_payload = response_future.custom_payload
    self.assertEqual(custom_payload, returned_custom_payload)
