diff --git a/benchmarks/callback_full_pipeline.py b/benchmarks/callback_full_pipeline.py
index 707d127c..7baa9194 100644
--- a/benchmarks/callback_full_pipeline.py
+++ b/benchmarks/callback_full_pipeline.py
@@ -42,7 +42,7 @@ class Runner(BenchmarkThread):
                 self.event.set()
 
         if next(self.num_started) <= self.num_queries:
-            future = self.session.execute_async(self.query, self.values)
+            future = self.session.execute_async(self.query, self.values, timeout=None)
             future.add_callbacks(self.insert_next, self.insert_next)
 
     def run(self):
diff --git a/cassandra/concurrent.py b/cassandra/concurrent.py
index 8d7743e1..b96c921b 100644
--- a/cassandra/concurrent.py
+++ b/cassandra/concurrent.py
@@ -138,7 +138,7 @@ def _handle_error(error, result_index, event, session, statements, results,
         return
 
     try:
-        future = session.execute_async(statement, params)
+        future = session.execute_async(statement, params, timeout=None)
         args = (next_index, event, session, statements, results, future, num_finished, to_execute, first_error)
         future.add_callbacks(
             callback=_execute_next, callback_args=args,
@@ -176,7 +176,7 @@ def _execute_next(result, result_index, event, session, statements, results,
         return
 
     try:
-        future = session.execute_async(statement, params)
+        future = session.execute_async(statement, params, timeout=None)
         args = (next_index, event, session, statements, results, future, num_finished, to_execute, first_error)
         future.add_callbacks(
             callback=_execute_next, callback_args=args,