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

Minor fixes to cassandra.concurrent docs

Browse Source
This commit is contained in:
Tyler Hobbs
2014-05-14 16:54:02 -05:00
parent e22270cd29
commit f48effc89b
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
cassandra/concurrent.py
View File

@@ -48,8 +48,8 @@ def execute_concurrent(session, statements_and_parameters, concurrency=100, rais
statements_and_params = []
for user_id in user_ids:
statatements_and_params.append(
(select_statement, user_id))
params = (user_id, )
statatements_and_params.append((select_statement, params))
results = execute_concurrent(
session, statements_and_params, raise_on_first_error=False)
@@ -97,9 +97,9 @@ def execute_concurrent(session, statements_and_parameters, concurrency=100, rais
def execute_concurrent_with_args(session, statement, parameters, *args, **kwargs):
"""
Like :meth:`~.execute_concurrent`, but takes a single statement and a
sequence of parameters. Each item in ``parameters`` should be a sequence
or :const:`None`.
Like :meth:`~cassandra.concurrent.execute_concurrent()`, but takes a single
statement and a sequence of parameters. Each item in ``parameters``
should be a sequence or :const:`None`.
Example usage::