For callback chaining, use old pattern of no-timeouts

aholmberg · aholmberg · commit f779da72d837 · 2015-06-19T13:01:10.000-05:00
Avoids the overhead of timer management when using the callback chaining
pattern.
diff --git a/benchmarks/callback_full_pipeline.py b/benchmarks/callback_full_pipeline.py
@@ -42,7 +42,7 @@ def insert_next(self, previous_result=sentinel):
                 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
@@ -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,
