diff --git a/cassandra/concurrent.py b/cassandra/concurrent.py index 607c29c332..ea1c94abf3 100644 --- a/cassandra/concurrent.py +++ b/cassandra/concurrent.py @@ -81,7 +81,7 @@ def _execute_next(self): def _execute(self, idx, statement, params): self._exec_depth += 1 try: - future = self.session.execute_async(statement, params, timeout=None, execution_profile=self._execution_profile) + future = self.session.execute_async(statement, params, execution_profile=self._execution_profile) args = (future, idx) future.add_callbacks( callback=self._on_success, callback_args=args,