IЦi SSKrSSKJrJrJr SSKJr SSKJrJ r J r /SQr \ \ \ \\S4r"SS\ \5r\"SS 55r"S S \ \5r\"S S 55rg)N)asdict dataclassfield)Enum)DictOptionalUnion) EventSourceEvent NodeState RdzvEventc \rSrSrSrSrSrSrg)r z)Known identifiers of the event producers.AGENTWORKERN)__name__ __module__ __qualname____firstlineno____doc__rr__static_attributes__rc/var/www/html/ai-image-ml/venv/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#r0dumpsrr&s rr%Event.serialize;zz&,''rrN)rrrrrr/__annotations__r rintrdictr!rEventMetadataValuer( staticmethodr r4r%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) rrrrrrBrCrDrErrrrr 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$)NrLr)r.r r/r0r1r r2s rr4RdzvEvent.deserializehsQ dI & &K dC  4(I"+Il,C"D ,%9%%rc@[R"[U55$r#r7r&s rr%RdzvEvent.serializeqr:rr)rrrrrr/r;r<r rNrOrrPrQr(r?r r4r%rrrrr r Hs I K LM HOSD(3-"Hhsm"K &%[ 01&k&&(3(rr )r0 dataclassesrrrenumrtypingrrr __all__r/r<floatboolr>r r r r rrrr^s 00(( =3UD$67#t (( (DT )()( )(r