summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2014-04-30 20:38:23 +0100
committerAsk Solem <ask@celeryproject.org>2014-04-30 20:38:23 +0100
commitb38e177c3ad9181d92a7125c12ca150d4130e823 (patch)
tree2a5d093088dea8ee0c403afb4442279594cab78a
parentb038684b0f4a671dbca0d906f9282698c0b9bc93 (diff)
downloadpy-amqp-b38e177c3ad9181d92a7125c12ca150d4130e823.tar.gz
Docstring wrong for transform
-rw-r--r--amqp/promise.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/amqp/promise.py b/amqp/promise.py
index 1541954..563caae 100644
--- a/amqp/promise.py
+++ b/amqp/promise.py
@@ -318,7 +318,7 @@ def _transback(filter_, callback, args, kwargs, ret):
return callback(ret)
-def transform(filter_, callback, *args, **kwargs):
+def transform(filter_, callback, *filter_args, **filter_kwargs):
"""Filter final argument to a promise.
E.g. to coerce callback argument to :class:`int`::
@@ -334,12 +334,12 @@ def transform(filter_, callback, *args, **kwargs):
def get_page_expires(self, url, callback=None):
return self.request(
'GET', url,
- callback=transform(get_key, 'PageExpireValue', int),
+ callback=transform(get_key, callback, 'PageExpireValue', int),
)
"""
callback = ensure_promise(callback)
- P = promise(_transback, (filter_, callback, args, kwargs))
+ P = promise(_transback, (filter_, callback, filter_args, filter_kwargs))
P.then(promise(), callback.throw)
return P