h dZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlmZmZmZ ddlZd ZeeefZd d d d d d d d d Zd Zej:ej<fdZdZ ddZ!dZ"GddeZ#dZ$ej:ej<fdZ%dZ&dZdZddZ'dZ(ejRe*fdddfdZ+dZ,y#e$rddlZYwxYw)z)Utilities for safely pickling exceptions.N) b64decode) b64encode)partial)getmro) takewhile) bytes_to_str safe_repr str_to_bytes)UnpickleableExceptionWrappersubclass_exceptionfind_pickleable_exceptioncreate_exception_clsget_pickleable_exceptionget_pickleable_etypeget_pickled_exception strtoboolFT)falseno0trueyes1onoffc"t||fd|iS)zCreate new exception class. __module__)type)nameparentmodules V/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/utils/serialization.pyr r !s vi,!7 88ct|dg}t|jtD]} ||}||||cSy#t$rY(wxYw)aFind first pickleable exception base class. With an exception instance, iterate over its super classes (by MRO) and find the first super exception that's pickleable. It does not go below :exc:`Exception` (i.e., it skips :exc:`Exception`, :class:`BaseException` and :class:`object`). If that happens you should use :exc:`UnpickleableException` instead. Arguments: exc (BaseException): An exception instance. loads: decoder to use. dumps: encoder to use Returns: Exception: Nearest pickleable parent exception class (except :exc:`Exception` and parents), or if the exception is pickleable it will return :const:`None`. argsN)getattritermro __class__unwanted_base_classes Exception)excloadsdumpsexc_argssuperclssuperexcs r!r r &s_(sFB'HCMM+@A *H %/ "OB   sA AAc4tfdt|S)Nc |vSN)supstops r!zitermro..Fs Dr")rr)clsr5s `r!r&r&Es 0&+ >>r"c,|st}t|||S)z&Dynamically create an exception class.)r)r )rr rs r!rrIs  dFF 33r"cg}|D]} |||j|t|S#t$r|jt|YOwxYw)aEnsure items will serialize. For a given list of arbitrary objects, return the object or a string representation, safe for serialization. Arguments: items (Iterable[Any]): Objects to serialize. encoder (Callable): Callable function to serialize with. )appendr)r tuple)itemsencoder safe_exc_argsargs r!ensure_serializabler@Ps]M 1 CL   %   1  3 0 1s/#AAcLeZdZdZdZdZdZdfd ZdZdZ e dZ xZ S)r atWraps unpickleable exceptions. Arguments: exc_module (str): See :attr:`exc_module`. exc_cls_name (str): See :attr:`exc_cls_name`. exc_args (Tuple[Any, ...]): See :attr:`exc_args`. Example: >>> def pickle_it(raising_function): ... try: ... raising_function() ... except Exception as e: ... exc = UnpickleableExceptionWrapper( ... e.__class__.__module__, ... e.__class__.__name__, ... e.args, ... ) ... pickle.dumps(exc) # Works fine. Nc|t|d}||_||_||_||_t |||||y)NcRtjtj|Sr2)pickler+r,)vs r!r6z7UnpickleableExceptionWrapper.__init__..s V\\!_ =r")r@ exc_module exc_cls_namer-textsuper__init__)selfrFrGr-rHr>r's r!rJz%UnpickleableExceptionWrapper.__init__sH+ = %(%   \= r"c\t|j|j|jSr2)rrGrFr-rKs r!restorez$UnpickleableExceptionWrapper.restores15#D$5$5$(OO56:mmE Er"c|jSr2)rHrMs r!__str__z$UnpickleableExceptionWrapper.__str__s yyr"c ||jj|jjt|dgt |}t |dr|j |j}|S)Nr$ __traceback__)r'r__name__r%r hasattrwith_tracebackrR)r7r*ress r!from_exceptionz+UnpickleableExceptionWrapper.from_exceptions` MM $ $ MM " " C $ cN   3 ($$S%6%67C r"r2) rSr __qualname____doc__rFrGr-rJrNrP classmethodrW __classcell__)r's@r!r r dsA*JLH E  r"r c tjtj||S#t$rYnwxYwt |}|r|St j |S)z"Make sure exception is pickleable.)rDr+r,r)r r rW)r*nearests r!rrs\ V\\#&'     (,G ' 6 6s ;;s (, 88cN ||||S#t$r tcYSwxYw)zGet pickleable exception type.)r))r7r+r,s r!rrs1 eCj  s $$cFt|tr|jS|S)z,Reverse of :meth:`get_pickleable_exception`.) isinstancer rN)r*s r!rrs#34{{} Jr"c<ttt|Sr2)r base64encoder ss r!rrs  \!_5 66r"c*tt|Sr2) base64decoder rcs r!rrs  Q ((r"c|t}t|tr ||jS|S#t$rt d|dwxYw)z_Convert common terms for true/false to bool. Examples (true/false/yes/no/on/off/1/0). zCannot coerce z to type bool)STRTOBOOL_DEFAULT_TABLEr`strlowerKeyError TypeError)termtables r!rrs]  }'$ D& & K DnTHMBC C Ds /AcTt|tjrB|j}|jr |dd|ddz}|j dr|dddz}|St|tj r#|j}|jr|dd}|S|jS)Nz+00:00iZ )r`datetime isoformat microsecondendswithtime)dtrs r!_datetime_to_jsonr{s"h''( LLN >>#223A ::h #2 A B & LLN >>#2A||~r"c ddlm}tt||||}t ||r|j d}| t ||r|St |t tfr|Dcgc] }|| c}St |tr8|jDcic]\}}|r ||r n ||||c}}St |tjtjfr t|St |tjr t|S|t!dt#|d|d |d ||Scc}wcc}}w) z;Transform object making it suitable for json serialization.r)Object) builtin_typeskey keyfilterunknown_type_filterT)recurse)rzUnsupported type:  z (parent: ))kombu.abstractr}rjsonifyr`as_dictr;listdictr<rtdaterxr{ timedeltari ValueErrorr) objr~rrr KombuDictType_jsonifyrEks r!rrs9 7wm!*+>@H#}%kk$k' {jm4 C% '%() )) C .1iik &*a ) ! q xq! !   C(--7 8 %% C++ ,3x  &$T#YM3'C5J #3''* s #D?!EcNtj}|s||d|ur||d)N)sysexc_info)r*rs r!raise_with_contextr s0||~H  !  8A;r"r2)-rYrtnumbersrbase64rrfrrb functoolsrinspectr itertoolsrkombu.utils.encodingrr r cPicklerD ImportError__all__r) BaseExceptionobjectr(rhr r+r,r r&rr@r rrrrr{Realrirrr3r"r!rs/ ,,FF #M6:$)U#'4!%e5 9 *0$*LL>?4 (:9:z <%+LL 7) &#<<-4 $(DysC CC