o hw@sLdZddlmZdZGdddZd ddZGd d d ZGd d d ZdS)z7Object related utilities, including introspection, etc.)reduce)BunchFallbackContextgetitem_property mro_lookupc@seZdZdZddZdS)rz-Object that enables you to modify attributes.cKs|j|dSN)__dict__update)selfkwargsr F/var/www/html/env/lib/python3.10/site-packages/celery/utils/objects.py__init__ szBunch.__init__N)__name__ __module__ __qualname____doc__rr r r r rs rNc Cs|stn|}|s gn|}|D]2}||vr:z |j|}|j}Wn ttfy.YdSw||vr7|SdS||jvrC|SqdS)a Return the first node by MRO order that defines an attribute. Arguments: cls (Any): Child class to traverse. attr (str): Name of attribute to find. stop (Set[Any]): A set of types that if reached will stop the search. monkey_patched (Sequence): Use one of the stop classes if the attributes module origin isn't in this list. Used to detect monkey patched attributes. Returns: Any: The attribute value, or :const:`None` if not found. N)setmrorrAttributeErrorKeyError)clsattrstopmonkey_patchednodevalue module_originr r r rs$     rc@s(eZdZdZddZddZddZdS) raContext workaround. 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, shouldn't close # after use yield connection else: # must've 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) cOs"||_||_||_||_d|_dSr)providedfallbackfb_args fb_kwargs_context)r rrr r!r r r rJs  zFallbackContext.__init__cCs2|jdur|jS|j|ji|j}|_|Sr)rrr r! __enter__r")r contextr r r r#Qs zFallbackContext.__enter__cGs|jdur |jj|SdSr)r"__exit__)r exc_infor r r r%Ys  zFallbackContext.__exit__N)rrrrrr#r%r r r r r.s  rc@s4eZdZdZd ddZddZd ddZd d ZdS) raAttribute -> dict key descriptor. The target object must support ``__getitem__``, and optionally ``__setitem__``. Example: >>> from collections import defaultdict >>> class Me(dict): ... deep = defaultdict(dict) ... ... foo = _getitem_property('foo') ... deep_thing = _getitem_property('deep.thing') >>> me = Me() >>> me.foo None >>> me.foo = 10 >>> me.foo 10 >>> me['foo'] 10 >>> me.deep_thing = 42 >>> me.deep_thing 42 >>> me.deep defaultdict(, {'thing': 42}) NcCs0|d\}}|_|r|dnd|_||_dS)N.) rpartitionkeysplitpathr)r keypathdocr+_r r r rs zgetitem_property.__init__cCs |jrtdd|g|jS|S)NcSs||Srr )dkr r r sz(getitem_property._path..)r+r)r objr r r _pathszgetitem_property._pathcCs|dur|S|||jSr)r3getr))r r2typer r r __get__szgetitem_property.__get__cCs||||j<dSr)r3r))r r2rr r r __set__szgetitem_property.__set__r)rrrrrr3r6r7r r r r r^s    r)NN)r functoolsr__all__rrrrr r r r s   0