o
    ^iY/                  
   @   s  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	 d dl
Z
d dlm  m  m  mZ d dl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% 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e0ee- ee1 f fddZ2de+de	ee-df de.e de3e1ef fddZ4dS )    N)	dataclassfield)AnyCallableOptionalUnion)get_default_numa_options)eventsmetrics)
WorkerSpec)LocalElasticAgent)DefaultLogsSpecs	LogsSpecsSignalException)ChildFailedError)RendezvousParameters)parse_rendezvous_endpoint)
get_logger)NumaOptions)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Ze
ed< dZee ed< dd ZdS ) r   a	  
    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.
        event_log_handler: name of the event logging handler as registered in
          `elastic/events/handlers.py <https://docs.pytorch.org/docs/stable/elastic/events.html>`_.


    .. 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_addrnullevent_log_handlernuma_optionsc                 C   s   d}| j dkr| j | jd< n
d| jvr|| jd< | jd u r!t | _| jd u r@tj rBtj | j	krDt
 | _td| j d S d S d S d S )Ni  r%   timeoutzUsing default numa options = %r)r&   r$   r   r   r1   torchcudais_availabledevice_countr   r   loggerinfo)selfdefault_timeout r;   Y/var/www/html/RAG/RAG_venv/lib/python3.10/site-packages/torch/distributed/launcher/api.py__post_init__c   s   




zLaunchConfig.__post_init__)__name__
__module____qualname____doc__int__annotations__r   r   r   r   strr   r    r"   r   dictr$   r   r&   r(   r)   floatr+   r,   r-   r.   r0   r1   r   r=   r;   r;   r;   r<   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)r9   rG   rH   r;   r;   r<   __init__   s   
zelastic_launch.__init__c                 G   s   t | j| jt|S rI   )r   rJ   rK   list)r9   argsr;   r;   r<   __call__   s   zelastic_launch.__call__)
r>   r?   r@   rA   r   r   r   rD   rL   rO   r;   r;   r;   r<   r   x   s    
r   rH   rN   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   -Nr;   ).0argr;   r;   r<   	<genexpr>   s    z'_get_entrypoint_name.<locals>.<genexpr>r   )
isinstancer   r>   rD   sys
executablenext)rH   rN   r;   r;   r<   _get_entrypoint_name   s   


rY   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   )rZ   r^   master_addrmaster_portr;   r;   r<   _get_addr_and_port   s   

rc   rG   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| j| jd td
| j| j| j | j	| j
| jd| j}t|\}}t| j| j|t|t|| j| j||| j| j| jd}t|| j| j| j d}	d}
zYz.t!"t!#| j |	$ }t%&|	' | j |( rt)||j*d|j+W W |
r|j,-  S S  t)y     t.y   d	}
t%&|	/ | j   t0y   t%&|	/ | j  w |
r|j,-  w w )Nz3config has no run_id, generated a random run_id: %saW  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
  event_log_handler  : %(event_log_handler)s
  numa_options       : %(numa_options)s
)rH   r   r   r   r   r"   r    r$   r(   r)   log_dirr-   r0   r1   )r]   r^   r   r   r   r.   )r   local_world_sizerH   rN   rdzv_handlerr(   r)   ra   rb   r.   r0   r1   )specr   r+   r,   T)namefailuresFr;   )1r   rD   uuiduuid4rB   r7   warningrY   r8   r   r   r   r"   r    r$   r(   r)   r   root_log_dirr-   r0   r1   r   r.   rc   r   r   tuplerdzv_registryget_rendezvous_handlerr   r+   r,   r
   initialize_metricsMetricsConfigrunr	   recordget_event_succeeded	is_failedr   ri   return_valuesrf   shutdownr   get_event_failed	Exception)rG   rH   rN   r   entrypoint_namerZ   ra   rb   rg   agentshutdown_rdzvresultr;   r;   r<   r      s   
"
r   )5rV   rj   dataclassesr   r   typingr   r   r   r   r3   -torch.distributed.elastic.rendezvous.registrydistributedelastic
rendezvousregistryro   torch._utils_internalr   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   torch.numa.bindingr   __all__r>   r7   r   r   rD   rM   rY   rn   rB   rc   rE   r   r;   r;   r;   r<   <module>   sT   R'


