diff options
author | Ask Solem <ask@celeryproject.org> | 2014-04-30 20:38:23 +0100 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2014-04-30 20:38:23 +0100 |
commit | b38e177c3ad9181d92a7125c12ca150d4130e823 (patch) | |
tree | 2a5d093088dea8ee0c403afb4442279594cab78a | |
parent | b038684b0f4a671dbca0d906f9282698c0b9bc93 (diff) | |
download | py-amqp-b38e177c3ad9181d92a7125c12ca150d4130e823.tar.gz |
Docstring wrong for transform
-rw-r--r-- | amqp/promise.py | 6 |
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 |