iSSKJr SSKrSSKJrJr SSKJrJrJ r SSK J r SSK J r "SS\5r"S S \5rSS jrSS jr"S S\5rg)) annotationsN)AnyType) BaseModelValidationErrormodel_validator)!import_module_from_qualified_name)Eventcv\rSrSr%SrS\S'S\S'S\S'S \S '/4SS jjr\SSS jj5rS r g)EventEnvelopeWithMetadataz Client readable representation of an Event. Includes class metadata in order to support matching event types semantically in an extendable manner (e.g. "StartEvent", "StopEvent", etc.). zdict[str, Any]value str | Nonequalified_namestrtypelist[str] | NonetypescUVs0sHo"RU_M nn[URURURS9R 5n[R XCS9$s snf)z Attempts to load the event data as a python class based on the envelope metadata. Looks up the event from the registry, if provided. Falls back to the qualified_name, attempting to load from the module path. )rrr) client_dataregistry)__name__ EventEnveloperrr model_dumpparse)selfreregistry_lookupas_event_envelopes `/home/james-whalen/.local/lib/python3.13/site-packages/workflows/protocol/serializable_events.py load_event$EventEnvelopeWithMetadata.load_eventsi 3;;(Q::q=(;)**499T=P=P *, "")#  37 "r/r c\rSrSr%SrS\S'SrS\S'SrS\S'\"S S 9\ SS j55r \ SS j5r \ SSS jj5r Sr g)rBz Client write representation of an Event. Includes class metadata in order to support matching event types semantically in an extendable manner (e.g. "StartEvent", "StopEvent", etc.). z Any | NonerNrrrbeforer%c[U[5(a[R"U5n[U[ 5(aSU;aSU;a 0UESUS0EnU$![Ra NDf=f)Nrdata) isinstancerr$loadsJSONDecodeErrordict)r)r>s r _format_compatibility#EventEnvelope._format_compatibilityLsu dC  zz$' dD ! !d"v~6$6f6 ''  sAA21A2cPU"URSS9[U5RS9$)Nr$r%)rr)rrr)r)r*s r r-EventEnvelope.from_eventZs-"""/e%%  r/c U=(d 0n/n[U[5(a[R"U5OUn[U[ 5(d [ S5eSU;=(d SU;=(a SU;nU(a8U(a1URU;a0UEURU0EnURUS.n[RU5nUR(avURU;a?URSURSSRUR5535 O'X'RRUR5$UR(ae[!UR5n[#U[$5(d URS URS 35 OURUR5$U(aUOS /n[ SRU55e![Ra UnGNf=f![&a'n URS [U 535 S n A NoS n A ff=f)ao Parse client data into an Event. Raises an EventValidationError if the client data is invalid. Args: client_data: The client data to parse. Can be a dictionary, a string, or an explicit Event class. registry: The registry of event type names to Event classes. explicit_event: An explicit Event class to treat the dict as Returns: The parsed Event. zNFailed to deserialize event. Must be a json object, or stringified json objectrrr)rrzInvalid event type: z. Expected one of z, z$Invalid client data. Qualified name z) does not correspond to an Event subclasszFailed to deserialize event: NzFInvalid client data. Must have a type or a qualified name, got {event} )r?rr$r@rArBEventValidationErrorrrmodel_validaterappendjoinkeysrrr issubclassr r) r)rrexplicit_eventerrorsas_dictmissing_qualifiersr* module_classrs r rEventEnvelope.parseas$>r "+5k3+G+G ;'[  '4((&`  G + DvW/D%W$  .&&h6PhP(?(?P&// G D!009Ezz::X-MM.uzzl:LTYYW_WdWdWfMgLhi$JJ/>>u{{KK##@AUAUV !,66MM>u?S?S>TT}~(66u{{CC$ Y #388F#344W## "!G "D D MM9#a&B C C Ds7-G29BHAH0H2H  H  IH;;Ir0)r>rr1r)r*r r1r)NN)rzdict[str, Any] | strrzdict[str, Type[Event]] | NonerOzType[Event] | Noner1r )rr3r4r5r6r7rrrr8rCr-rr9r0r/r rrBs D*!%NJ%(# $   37-1 B5)B50B5+ B5  B5B5r/rc/nUR5SSH@nU[La O6[U[5(dM%URUR5 MB U(dgU$)zg Traverses the MRO (Module Resolution Order) of a class and returns the list of only Event subclasses. N)mror rNrKr)r)namescs r r(r(sSE WWYqr] :  a   LL $   Lr/c8URSUR3$)N.)r3r)r*s r r'r's q 0 11r/c\rSrSrSrSrg)rIz'Raised when the client data is invalid.r0N)rr3r4r5r6r9r0r/r rIrIs1r/rI)r) Type[Event]r1r)r*r^r1r) __future__rr$typingrrpydanticrrrworkflows.context.utilsr workflows.eventsr r rr(r' ExceptionrIr0r/r resN# @@E"1 1hb5Ib5J  2292r/