o
    ߗi*                  
   @   sx  d dl Z d dlZd dlmZmZ d dlmZmZmZm	Z	m
Z
mZmZ d dlm  m  m  mZ d dlmZmZ d dlmZ d dlmZ d dlmZmZmZ d dlmZ d d	l m!Z! d d
l"m#Z# d dl$m%Z% g dZ&e%e'Z(eG dd dZ)G dd dZ*deee+df de	e de+fddZ,de!dee
e+ e
e- f fddZ.de)deee+df de	e dee-ef fddZ/dS )    N)	dataclassfield)AnyCallableDictListOptionalTupleUnion)eventsmetrics)
WorkerSpec)LocalElasticAgent)DefaultLogsSpecs	LogsSpecsSignalException)ChildFailedError)RendezvousParameters)parse_rendezvous_endpoint)
get_logger)LaunchConfigelastic_launchlaunch_agentc                   @   s   e Zd ZU dZeed< eed< eed< dZee ed< dZ	e
ed< d	Ze
ed
< dZe
ed< dZe
ed< eedZee
ef ed< dZeed< dZeed< dZeed< dZe
ed< dZee
 ed< eedZee
e
f ed< dZee
 ed< dd ZdS )r   aM  
    Creates a rendezvous config.

    Args:
        min_nodes: Minimum amount of nodes that the user function will
                        be launched on. Elastic agent ensures that the user
                        function start only when the min_nodes amount enters
                        the rendezvous.
        max_nodes: Maximum amount of nodes that the user function
                        will be launched on.
        nproc_per_node: On each node the elastic agent will launch
                            this amount of workers that will execute user
                            defined function.
        rdzv_backend: rdzv_backend to use in the rendezvous (zeus-adapter, etcd).
        rdzv_endpoint: The endpoint of the rdzv sync. storage.
        rdzv_configs: Key, value pair that specifies rendezvous specific configuration.
        rdzv_timeout: Legacy argument that specifies timeout for the rendezvous. It is going
            to be removed in future versions, see the note below. The default timeout is 900 seconds.
        run_id: The unique run id of the job (if not passed a unique one will be
                deduced from run environment - flow workflow id in flow - or auto generated).
        role: User defined role of the worker (defaults to "trainer").
        max_restarts: The maximum amount of restarts that elastic agent will conduct
                    on workers before failure.
        monitor_interval: The interval in seconds that is used by the elastic_agent
                        as a period of monitoring workers.
        start_method: The method is used by the elastic agent to start the
                    workers (spawn, fork, forkserver).
        metrics_cfg: configuration to initialize metrics.
        local_addr: address of the local node if any. If not set, a lookup on the local
                machine's FQDN will be performed.
        local_ranks_filter: ranks for which to show logs in console. If not set, show from all.
    ..note:
        `rdzv_timeout` is a legacy argument that will be removed in future.
        Set the timeout via `rdzv_configs['timeout']`

    	min_nodes	max_nodesnproc_per_nodeN
logs_specs run_iddefault_rolerolerdzv_endpointetcdrdzv_backend)default_factoryrdzv_configsrdzv_timeout   max_restartsg?monitor_intervalspawnstart_methodlog_line_prefix_templatemetrics_cfg
local_addrc                 C   sJ   d}| j dkr| j | jd< n
d| jvr|| jd< | jd u r#t | _d S d S )Ni  r&   timeout)r'   r%   r   r   )selfdefault_timeout r3   \/home/ubuntu/transcripts/venv/lib/python3.10/site-packages/torch/distributed/launcher/api.py__post_init__Z   s   



zLaunchConfig.__post_init__)__name__
__module____qualname____doc__int__annotations__r   r   r   r   strr    r!   r#   r   dictr%   r   r   r'   r)   r*   floatr,   r-   r.   r/   r5   r3   r3   r3   r4   r   "   s&   
 %r   c                   @   s4   e Zd ZdZdedeeedf fddZdd Z	dS )	r   a  
    Launches an torchelastic agent on the container that invoked the entrypoint.

        1. Pass the ``entrypoint`` arguments as non ``kwargs`` (e.g. no named parameters)/
           ``entrypoint`` can be a function or a command.
        2. The return value is a map of each worker's output mapped
           by their respective global rank.

    Usage

    ::

    def worker_fn(foo):
        # ...

    def main():
        # entrypoint is a function.
        outputs = elastic_launch(LaunchConfig, worker_fn)(foo)
        # return rank 0's output
        return outputs[0]

        # entrypoint is a command and ``script.py`` is the python module.
        outputs = elastic_launch(LaunchConfig, "script.py")(args)
        outputs = elastic_launch(LaunchConfig, "python")("script.py")
    config
entrypointNc                 C   s   || _ || _d S N)_config_entrypoint)r1   r?   r@   r3   r3   r4   __init__   s   
zelastic_launch.__init__c                 G   s   t | j| jt|S rA   )r   rB   rC   list)r1   argsr3   r3   r4   __call__   s   zelastic_launch.__call__)
r6   r7   r8   r9   r   r
   r   r<   rD   rG   r3   r3   r3   r4   r   f   s    
r   r@   rF   returnc                 C   s@   t | tr| jS t | tr| tjkrtdd |D dS | S dS )a  Retrieve entrypoint name with the rule:
    1. If entrypoint is a function, use ``entrypoint.__qualname__``.
    2. If entrypoint is a string, check its value:
        2.1 if entrypoint equals to ``sys.executable`` (like "python"), use the first element from ``args``
            which does not start with hifen letter (for example, "-u" will be skipped).
        2.2 otherwise, use ``entrypoint`` value.
    3. Otherwise, return empty string.
    c                 s   s     | ]}|d  dkr|V  qdS )r   -Nr3   ).0argr3   r3   r4   	<genexpr>   s    z'_get_entrypoint_name.<locals>.<genexpr>r   )
isinstancer   r6   r<   sys
executablenext)r@   rF   r3   r3   r4   _get_entrypoint_name   s   


rQ   rdzv_parametersc                 C   sX   | j dkrdS | j}| }|stdt|dd\}}|dkr(td| d||fS )Nstatic)NNzKEndpoint is missing in endpoint. Try to add --master-addr and --master-portr&   )default_portzport is missing in endpoint: z. Try to specify --master-port)backendendpointstrip
ValueErrorr   )rR   rV   master_addrmaster_portr3   r3   r4   _get_addr_and_port   s   

r[   r?   c                 C   s  | j stt j}td| || _ t||}td|| j	| j
| j| j | j| j| j| j| j| jj| jd td
| j| j| j | j	| j
| jd| j}t|\}}t| j| j|t|t|| j| j||| jd
}t|| j| j| jd}	d}
zSz,t t!| j |	" }t#$|	%  |& rt'||j(d|j)W W |
r|j*+  S S  t'y     t,y   d	}
t#$|	-    t.y   t#$|	-   w |
r|j*+  w w )Nz3config has no run_id, generated a random run_id: %sa  Starting elastic_operator with launch configs:
  entrypoint       : %(entrypoint)s
  min_nodes        : %(min_nodes)s
  max_nodes        : %(max_nodes)s
  nproc_per_node   : %(nproc_per_node)s
  run_id           : %(run_id)s
  rdzv_backend     : %(rdzv_backend)s
  rdzv_endpoint    : %(rdzv_endpoint)s
  rdzv_configs     : %(rdzv_configs)s
  max_restarts     : %(max_restarts)s
  monitor_interval : %(monitor_interval)s
  log_dir          : %(log_dir)s
  metrics_cfg      : %(metrics_cfg)s
)r@   r   r   r   r   r#   r!   r%   r)   r*   log_dirr.   )rU   rV   r   r   r   r/   )
r    local_world_sizer@   rF   rdzv_handlerr)   r*   rY   rZ   r/   )specr   r,   r-   T)namefailuresFr3   )/r   r<   uuiduuid4r:   loggerwarningrQ   infor   r   r   r#   r!   r%   r)   r*   r   root_log_dirr.   r   r/   r[   r   r    tuplerdzv_registryget_rendezvous_handlerr   r,   r-   r   initialize_metricsMetricsConfigrunr   recordget_event_succeeded	is_failedr   ra   return_valuesr^   shutdownr   get_event_failed	Exception)r?   r@   rF   r   entrypoint_namerR   rY   rZ   r_   agentshutdown_rdzvresultr3   r3   r4   r      s   

r   )0rN   rb   dataclassesr   r   typingr   r   r   r   r   r	   r
   -torch.distributed.elastic.rendezvous.registrydistributedelastic
rendezvousregistryri   torch.distributed.elasticr   r   *torch.distributed.elastic.agent.server.apir   :torch.distributed.elastic.agent.server.local_elastic_agentr   )torch.distributed.elastic.multiprocessingr   r   r   0torch.distributed.elastic.multiprocessing.errorsr   $torch.distributed.elastic.rendezvousr   *torch.distributed.elastic.rendezvous.utilsr   'torch.distributed.elastic.utils.loggingr   __all__r6   rd   r   r   r<   rQ   r:   r[   r   r3   r3   r3   r4   <module>   sN   $C'


