ȅi SSKrSSKJrJrJr SSKJr SSKJr /SQr \\ \ \ \ S4r"SS\ \5r\"SS 55r"S S \ \5r\"S S 55rg)N)asdict dataclassfield)Enum)Union) EventSourceEvent NodeState RdzvEventc \rSrSrSrSrSrSrg)rz)Known identifiers of the event producers.AGENTWORKERN)__name__ __module__ __qualname____firstlineno____doc__rr__static_attributes__r^/home/james-whalen/.local/lib/python3.13/site-packages/torch/distributed/elastic/events/api.pyrrs3 E Frrc\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 strjsonloadsrr) 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__rrintrdictrEventMetadataValuer& staticmethodrr2r#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) rrrrrr@rArBrCrrrrr r @s6 DGI Frr c\rSrSr%Sr\\S'\\S'\\S'\\S'\\S'\\S'S r \\S 'S r \S -\S 'S r \S -\S 'S r \\S'Sr \S\\S4SS4Sj5rS\4SjrSrg )r IaX 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__fr(rr)r*c[U[5(aU$[U[5(a[R"U5n[ WSUS'[S0UD6$)NrJr)r,r r-r.r/r r0s rr2RdzvEvent.deserializeisQ dI & &K dC  4(I"+Il,C"D ,%9%%rc@[R"[U55$r!r5r$s rr#RdzvEvent.serializesr8rr)rrrrrr-r9r:r rLrMrNrOr&r=rr2r#rrrrr r Is I K LM HOSD#*HcDjK &%[ 01&k&&(3(rr )r. dataclassesrrrenumrtypingr__all__r-r:floatboolr<rr r r rrrr\s 00 =3UD$67#t  ( (  (FT *(*( *(r