utils.mattrgetter(*attrs) Like operator.itemgetter() but returns None on missing attributes instead of raising AttributeError. celery.utils.mitemgetter(*items) Like operator.itemgetter() but returns None import dmap >>> import operator >>> dmap(operator.add, [[2, 2], [4, 4], [8, 8]]) >>> [4, 8, 16] >>> from celery.task import dmap_async >>> import operator >>> result = dmap_async(operator.add, [[2, 2], [4,

arguments and collect the results. Example >>> from celery.task import dmap >>> import operator >>> dmap(operator.add, [[2, 2], [4, 4], [8, 8]]) [4, 8, 16] celery.task.dmap_async(fun, args, timeout=None) result.AsyncResult: Example >>> from celery.task import dmap_async >>> import operator >>> presult = dmap_async(operator.add, [[2, 2], [4, 4], [8, 8]]) >>> presult Python versions, see: http://bugs.python.org/issue4978. celery.utils.mattrgetter(*attrs) Like operator.itemgetter() but returns None on missing attributes instead of raising AttributeError. celery.utils

utils.mattrgetter(*attrs) Like operator.itemgetter() but returns None on missing attributes instead of raising AttributeError. celery.utils.mitemgetter(*items) Like operator.itemgetter() but returns None import dmap >>> import operator >>> dmap(operator.add, [[2, 2], [4, 4], [8, 8]]) >>> [4, 8, 16] >>> from celery.task import dmap_async >>> import operator >>> result = dmap_async(operator.add, [[2, 2], [4,

Python versions, see: http://bugs.python.org/issue4978. celery.utils.mattrgetter(*attrs) Like operator.itemgetter() but returns None on missing attributes instead of raising AttributeError. celery.utils maybe_promise(value) Evaluates if the value is a promise. celery.utils.mitemgetter(*items) Like operator.itemgetter() but returns None on missing items instead of raising KeyError. class celery.utils import dmap >>> import operator >>> dmap(operator.add, [[2, 2], [4, 4], [8, 8]]) >>> [4, 8, 16] >>> from celery.task import dmap_async >>> import operator >>> result = dmap_async(operator.add, [[2, 2], [4,

arguments and collect the results. Example >>> from celery.task import dmap >>> import operator >>> dmap(operator.add, [[2, 2], [4, 4], [8, 8]]) [4, 8, 16] celery.task.dmap_async(fun, args, timeout=None) result.AsyncResult: Example >>> from celery.task import dmap_async >>> import operator >>> presult = dmap_async(operator.add, [[2, 2], [4, 4], [8, 8]]) >>> presult Python versions, see: http://bugs.python.org/issue4978. celery.utils.mattrgetter(*attrs) Like operator.itemgetter() but returns None on missing attributes instead of raising AttributeError. celery.utils

Python versions, see: http://bugs.python.org/issue4978. celery.utils.mattrgetter(*attrs) Like operator.itemgetter() but returns None on missing attributes instead of raising AttributeError. celery.utils maybe_promise(value) Evaluates if the value is a promise. celery.utils.mitemgetter(*items) Like operator.itemgetter() but returns None on missing items instead of raising KeyError. class celery.utils import dmap >>> import operator >>> dmap(operator.add, [[2, 2], [4, 4], [8, 8]]) >>> [4, 8, 16] >>> from celery.task import dmap_async >>> import operator >>> result = dmap_async(operator.add, [[2, 2], [4,

call the signature with partial args/kwargs. Note In this tutorial I sometimes use the prefix operator ~ to signatures. You probably shouldn’t use it in your production code, but it’s a handy shortcut Chains can also be made using the | (pipe) operator: >>> (add.s(2, 2) | mul.s(8) | mul.s(10)).apply_async() Note It’s not possible to synchronize sunfinite. Nested chains now works properly when constructed using the chain type instead of the | operator (Issue #1656 [https://github.com/celery/celery/issues/1656]). 3.1.4 release-date: 2013-11-15 11:40

call the signature with partial args/kwargs. Note In this tutorial I sometimes use the prefix operator ~ to signatures. You probably shouldn’t use it in your production code, but it’s a handy shortcut Chains can also be made using the | (pipe) operator: >>> (add.s(2, 2) | mul.s(8) | mul.s(10)).apply_async() Graphs In addition you can work with html#SystemExit]. connection event_from_message(body, localize=True, now=, tzfields=<operator.itemgetter object>, adjust_timestamp=, CLIENT_CLOCK_SKEW=-1) get_consumers(Consumer

call the signature with partial args/kwargs. Note In this tutorial I sometimes use the prefix operator ~ to signatures. You probably shouldn’t use it in your production code, but it’s a handy shortcut Chains can also be made using the | (pipe) operator: >>> (add.s(2, 2) | mul.s(8) | mul.s(10)).apply_async() Graphs In addition you can work with html#SystemExit]. connection event_from_message(body, localize=True, now=, tzfields=<operator.itemgetter object>, adjust_timestamp=, CLIENT_CLOCK_SKEW=-1) get_consumers(Consumer

call the signature with partial args/kwargs. Note In this tutorial I sometimes use the prefix operator ~ to signatures. You probably shouldn’t use it in your production code, but it’s a handy shortcut Chains can also be made using the | (pipe) operator: >>> (add.s(2, 2) | mul.s(8) | mul.s(10)).apply_async() Graphs In addition you can work with html#SystemExit]. connection event_from_message(body, localize=True, now=, tzfields=<operator.itemgetter object>, adjust_timestamp=, CLIENT_CLOCK_SKEW=-1) get_consumers(Consumer