openstack/deb-python-cassandra-driver
Code Issues Proposed changes

Fixed call to next

Browse Source
This commit is contained in:
Tim Savage
2014-03-22 00:09:37 +11:00
parent 3fa2133625
commit e32d79f451
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
benchmarks/callback_full_pipeline.py
View File

@@ -24,10 +24,10 @@ class Runner(BenchmarkThread):
if previous_result is not sentinel: if previous_result is not sentinel:
if isinstance(previous_result, BaseException): if isinstance(previous_result, BaseException):
log.error("Error on insert: %r", previous_result) log.error("Error on insert: %r", previous_result)
if self.num_finished.next() >= self.num_queries: if next(self.num_finished) >= self.num_queries:
self.event.set() self.event.set()
if self.num_started.next() <= self.num_queries: 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)
future.add_callbacks(self.insert_next, self.insert_next) future.add_callbacks(self.insert_next, self.insert_next)