[Th SSKrSSKJrJrJr SSKJr SSKJrJ r /SQr \ \ \ \ \S4r"SS\ \5r\"SS 55r"S S \ \5r\"S S 55rg)N)asdict dataclassfield)Enum)OptionalUnion) EventSourceEvent NodeState RdzvEventc \rSrSrSrSrSrSrg)r z)Known identifiers of the event producers.AGENTWORKERN)__name__ __module__ __qualname____firstlineno____doc__rr__static_attributes__r\/var/www/auris/envauris/lib/python3.13/site-packages/torch/distributed/elastic/events/api.pyr r s3 E Frr c\rSrSr%Sr\\S'\\S'Sr\ \S'\ "\ S9r \ \\ 4\S'S r\S \\S4S S4S j5rS \4S jrSrg)r a] The class represents the generic event that occurs during the torchelastic job execution. The event can be any kind of meaningful action. Args: name: event name. source: the event producer, e.g. agent or worker timestamp: timestamp in milliseconds when event occurred. metadata: additional data that is associated with the event. namesourcer timestamp)default_factorymetadatac"UR5$N serializeselfs r__str__ Event.__str__/~~rdatareturnc[U[5(aU$[U[5(a[R"U5n[ WSUS'[S0UD6$)Nrr) isinstancer strjsonloadsr r* data_dicts r deserializeEvent.deserialize2sQ dE " "K dC  4(I))H*=> (!y!!rc@[R"[U55$r"r/dumpsrr%s rr$Event.serialize;zz&,''rrN)rrrrrr.__annotations__r rintrdictr EventMetadataValuer' staticmethodrr3r$rrrrr r st  I Is.3D.IHd3**+I "%W -"'""(3(rr c(\rSrSrSrSrSrSrSrSr g) r ?z,The states that a node can be in rendezvous.INITRUNNING SUCCEEDEDFAILEDrN) rrrrrrArBrCrDrrrrr r ?s6 DGI Frr c\rSrSr%Sr\\S'\\S'\\S'\\S'\\S'\\S'S r \\S 'S r \ \\S 'S r \ \\S 'S r \\S'Sr\S\\S4SS4Sj5rS\4SjrSrg )r HaX Dataclass to represent any rendezvous event. Args: name: Event name. (E.g. Current action being performed) run_id: The run id of the rendezvous message: The message describing the event hostname: Hostname of the node pid: The process id of the node node_state: The state of the node (INIT, RUNNING, SUCCEEDED, FAILED) master_endpoint: The master endpoint for the rendezvous store, if known rank: The rank of the node, if known local_id: The local_id of the node, if defined in dynamic_rendezvous.py error_trace: Error stack trace, if this is an error event. rrun_idmessagehostnamepid node_statemaster_endpointNranklocal_id error_tracec"UR5$r"r#r%s rr'RdzvEvent.__str__er)rr*r+c[U[5(aU$[U[5(a[R"U5n[ WSUS'[S0UD6$)NrKr)r-r r.r/r0r r1s rr3RdzvEvent.deserializehsQ dI & &K dC  4(I"+Il,C"D ,%9%%rc@[R"[U55$r"r6r%s rr$RdzvEvent.serializeqr9rr)rrrrrr.r:r;r rMrNrrOrPr'r>rr3r$rrrrr r Hs I K LM HOSD(3-"Hhsm"K &%[ 01&k&&(3(rr )r/ dataclassesrrrenumrtypingrr__all__r.r;floatboolr=r r r r rrrr]s 00" =3UD$67#t (( (DT )()( )(r