diff --git a/cassandra/concurrent.py b/cassandra/concurrent.py index 0e7bf794e0..6cf4e0df57 100644 --- a/cassandra/concurrent.py +++ b/cassandra/concurrent.py @@ -143,7 +143,7 @@ def _execute(self, idx, statement, params): while self._pending_executions: p_idx, p_statement, p_params = self._pending_executions.pop(0) try: - future = self.session.execute_async(p_statement, p_params, timeout=None, execution_profile=self._execution_profile) + future = self.session.execute_async(p_statement, p_params, execution_profile=self._execution_profile) args = (future, p_idx) future.add_callbacks( callback=self._on_success, callback_args=args,