U yhk)@sddlZddlmZddlmZmZddlmZmZm Z m Z m Z m Z m Z mZddlZddlmZeGdddZGddde ZGd d d ZGd d d ZdS) N)contextmanager) dataclassfield)AnyCallableDictList NamedTupleOptionalSetTuplec@sDeZdZUdZeejjdZejje d<dZ e e e efe d<dS) TracingConfiga This represents a symbolic tracing configuration. Args: tracer (torch.fx.Tracer): An instance of :class:`torch.fx.Tracer` to use for symbolic tracing. The default value is the native :class:`torch.fx.Tracer` constructed with default arguments. However, the user may want to pass a different value such as the ``HFTracer`` for models in the HuggingFace Transformers_ library. .. _Transformers: https://huggingface.co/docs/transformers/index concrete_args (Optional[Dict[str, Any]]): Concrete arguments that should not be treated as ``torch.fx.Proxy`` when tracing the module ``forward()``. Passing ``concrete_args`` allows partially specializing the forward, e.g. to remove control flow or data structures. This ``concrete_args`` here is the same argument used in :meth:`~torch.fx.Tracer.trace`. )default_factorytracerN concrete_args)__name__ __module__ __qualname____doc__rtorchfxTracerr__annotations__rr rstrrrrU/var/www/html/venv/lib/python3.8/site-packages/torch/distributed/fsdp/_trace_utils.pyr s r c@s2eZdZUdZejed<eee ej fed<dS)_ParamUsageInfoa6 This is used for ``_ExecutionInfo.module_to_param_usage_infos`` to record execution information. The ``dict`` maps modules to a list of these ``_ParamUsageInfo`` instances, where each instance represents a group of parameters used together. Specifically, for each module key in the ``dict``, each instance of this class represents either: (1) the module and some sublist of its ``named_parameters()`` used together in execution (see ``_patched_create_proxy()``), or (2) a submodule and all of ``submodule.named_parameters()`` (see ``_patched_call_module()``). Type (1) corresponds to directly using parameters in ops without calling ``forward()``, and type (2) corresponds to calling ``forward()``. The mapped-to lists in the ``dict`` follow the execution order. module named_paramsN) rrrrnnModulerrr r Parameterrrrrr#s  rc@s"eZdZdZejddddZdS)_ExecutionInfoa1 This represents the execution order information from the forward pass. Attributes: curr_module (nn.Module): Current module being traced. module_forward_order (List[nn.Module]): The modules in (pre-)forward order, i.e. the order in which their ``forward()`` methods are called. Each call to a module's ``forward()`` corresponds to one element in the list. module_to_param_usage_infos (Dict[nn.Module, List[_ParamUsageInfo]]): Maps a module to a list of module execution infos. See :class:`_ParamUsageInfo` for details. param_forward_order (List[nn.Parameter]): The parameters in forward execution order, where only a parameter's first participation is included. visited_params (Set[nn.Parameter]): The parameters visited so far during the trace. This is only used during tracing for fast membership check. Invariant: The parameters in ``param_forward_order`` are exactly those in ``visited_params``. N) root_modulereturncCs*||_|g|_|gi|_g|_t|_dSN) curr_modulemodule_forward_ordermodule_to_param_usage_infosparam_forward_ordersetvisited_params)selfr#rrr__init__Psz_ExecutionInfo.__init__)rrrrrr r-rrrrr":sr"c@seZdZddddZeejjej dddZ e e ej e e edfeeefed d d Zde e eeejfeejjje edfeeefeeeeee ejjgejjfejjd d dZdS)_ExecOrderTracerN)r$cCs d|_dSr%) exec_info)r,rrrr-[sz_ExecOrderTracer.__init__)rr#ccsjt||_|j}|j}t|j||j|_t|}t|j ||j||_z dVW5||_||_XdSr%) r"r/ call_module create_proxy functoolspartial_patched_call_moduledictnamed_parameters_patched_create_proxy)r,rr#Zorig_call_moduleZorig_create_proxy fqn_to_paramrrr patch_tracer^s&   z_ExecOrderTracer.patch_tracer.)r0r/rforwardargskwargsr$c Csx|j|t|}|j}|rL||jks4td|j|jt|||} ||_g|j|<|||||} | |_| S)a Overrides ``call_module`` to save execution information to ``exec_info``. Note that ``call_module`` is called during symbolic tracing for each non-root module. Args: call_module (Callable): Original ``call_module`` to override. exec_info (_ExecutionInfo): Used to record execution information. module (nn.Module): Module corresponding to this ``call_module``. forward (Callable): ``forward()`` method of ``module`` to be called for this ``call_module``. args (Tuple[Any, ...]): Positional arguments for ``forward``. kwargs (Dict[str, Any]): Keyword arguments for ``forward``. Returns: Same return value as ``call_module``. zPThe current module should have already been processed by a patched `call_module`)r'appendlistr6r&r(AssertionErrorr) r,r0r/rr:r;r<rr&Zprev_curr_moduleoutputrrrr4ss"    z%_ExecOrderTracer._patched_call_module) r1r/r8kindtargetr;r<name type_exprproxy_factory_fnr$c Cs||||||| | } |j} |dkr|dk rg} |D]^}t|tjjr2|jj|kr2||jj}| |jj|f||jkr2|j ||j |q2| r|j | t | | n`|dkrt | } | r|j | t | | | D]*\}}||jkr|j ||j |q| S)a Overrides ``create_proxy`` to save execution information to ``exec_info``. Note that ``create_proxy`` is called during symbolic tracing for each leaf function/method/module. Args: create_proxy (Callable): Original ``create_proxy`` to override. exec_info (_ExecutionInfo): Used to record execution information. fqn_to_param (Dict[str, nn.Parameter]): ``dict`` version of the root module's ``named_parameters()`` with FQN as key and parameter as value. kind (str): Kind of the target method ('call_function', 'call_method', 'get_attr', 'call_module', 'placeholder', or 'output'). See :class:`torch.fx.Graph` for details. This is passed to ``create_proxy``. target (torch.fx.node.Target): Contains the string name of the function/method/module. This is passed to ``create_proxy``. args (Tuple[Any, ...]): Positional arguments for the function/ method/module. This is passed to ``create_proxy``. kwargs (Dict[str, Any]): Keyword arguments for the function/method/ module. This is passed to ``create_proxy`` name (Optional[str]): An optional string name for the ``Node`` created in ``create_proxy``. This is passed to ``create_proxy``. type_expr (Optional[Any]): An optional type annotation representing the Python type that the output of the node has. This is passed to ``create_proxy``. proxy_factory_fn (Callable[[torch.fx.Node], torch.fx.Proxy]): An alternative proxy constructor used in ``create_proxy``. This is passed to ``create_proxy``. Returns: torch.fx.Proxy: Created ``Node`` wrapped in a ``Proxy`` object. )Z call_functionZ call_methodNr0)r& isinstancerrProxynoderBr=r+addr)r(rr>r6)r,r1r/r8rArBr;r<rCrDrEproxyr&rargparam_rrrr7sL0            z&_ExecOrderTracer._patched_create_proxy)NNN)rrrr-rrrrrr r9rr"r rrrr4r!rHZTargetr NoderGr7rrrrr.Zs6   6   r.)r2 contextlibr dataclassesrrtypingrrrrr r r r rZtorch.nnrr rr"r.rrrrs (