ó P'—^c@@s^dZddlmZdgZdefd„ƒYZd gd„Zdefd„ƒYZd S( sp celery.utils.objects ~~~~~~~~~~~~~~~~~~~~ Object related utilities including introspection, etc. i(tabsolute_importt mro_lookuptBunchcB@seZdZd„ZRS(s-Object that enables you to modify attributes.cK@s|jj|ƒdS(N(t__dict__tupdate(tselftkwargs((s6/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/objects.pyt__init__s(t__name__t __module__t__doc__R(((s6/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/objects.pyRscC@s‚x{|jƒD]m}||krgy|j|}|j}Wnttfk rRnX||krc|SdS||jkr |Sq WdS(seReturn the first node by MRO order that defines an attribute. :keyword stop: A list of types that if reached will stop the search. :keyword monkey_patched: Use one of the stop classes if the attr's module origin is not in this list, this to detect monkey patched attributes. :returns None: if the attribute was not found. N(tmroRR tAttributeErrortKeyError(tclstattrtstoptmonkey_patchedtnodet module_origin((s6/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/objects.pyRs     tFallbackContextcB@s)eZdZd„Zd„Zd„ZRS(sĪThe built-in ``@contextmanager`` utility does not work well when wrapping other contexts, as the traceback is wrong when the wrapped context raises. This solves this problem and can be used instead of ``@contextmanager`` in this example:: @contextmanager def connection_or_default_connection(connection=None): if connection: # user already has a connection, should not close # after use yield connection else: # must have new connection, and also close the connection # after the block returns with create_new_connection() as connection: yield connection This wrapper can be used instead for the above like this:: def connection_or_default_connection(connection=None): return FallbackContext(connection, create_new_connection) cO@s1||_||_||_||_d|_dS(N(tprovidedtfallbacktfb_argst fb_kwargstNonet_context(RRRRR((s6/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/objects.pyRJs     cC@s?|jdk r|jS|j|j|jŽjƒ}|_|S(N(RRRRRt __enter__R(Rtcontext((s6/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/objects.pyRQs cG@s#|jdk r|jj|ŒSdS(N(RRt__exit__(Rtexc_info((s6/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/objects.pyRYs(RR R RRR(((s6/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/objects.pyR/s  N((R t __future__Rt__all__tobjectRRR(((s6/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/objects.pyts