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

Merge pull request #197 from victorpoluceno/master

Browse Source 
Makes execute_concurrent function compatible with Python 2.6
This commit is contained in:
Adam Holmberg
2014-09-23 09:25:16 -05:00
parent d76d48ee15 133185e495
commit ad2f61f865
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cassandra/concurrent.py
View File

@@ -83,7 +83,7 @@ def execute_concurrent(session, statements_and_parameters, concurrency=100, rais
first_error = [] if raise_on_first_error else None first_error = [] if raise_on_first_error else None
to_execute = len(statements_and_parameters) to_execute = len(statements_and_parameters)
results = [None] * to_execute results = [None] * to_execute
num_finished = count(start=1) num_finished = count(1)
statements = enumerate(iter(statements_and_parameters)) statements = enumerate(iter(statements_and_parameters))
for i in xrange(min(concurrency, len(statements_and_parameters))): for i in xrange(min(concurrency, len(statements_and_parameters))):
_execute_next(_sentinel, i, event, session, statements, results, None, num_finished, to_execute, first_error) _execute_next(_sentinel, i, event, session, statements, results, None, num_finished, to_execute, first_error)