kedro/pipeline/pipeline.py
def _get_nodes_with_inputs_transcode_compatible(
        self, datasets: Set[str]
    ) -> Set[Node]:
        """Retrieves nodes that use the given `datasets` as inputs.
        If provided a name, but no format, for a transcoded dataset, it
        includes all nodes that use inputs with that name, otherwise it
        matches to the fully-qualified name only (i.e. name@format).

        Raises:
            ValueError: if any of the given datasets do not exist in the
                ``Pipeline`` object

        Returns:
            Set of ``Nodes`` that use the given datasets as inputs.
        """
        missing = sorted(
            datasets - self.data_sets() - self._transcode_compatible_names()
        )
        if missing:
            raise ValueError(
                "Pipeline does not contain data_sets named {}".format(missing)
            )

        relevant_nodes = set()
        for input_ in datasets:
            if _strip_transcoding(input_) == input_:
                relevant_nodes.update(self._nodes_by_input[_strip_transcoding(input_)])
            else:
                for node_ in self._nodes_by_input[_strip_transcoding(input_)]:
                    if input_ in node_.inputs:
                        relevant_nodes.add(node_)
        return relevant_nodes
Retrieves nodes that use the given `datasets` as inputs.
        If provided a name, but no format, for a transcoded dataset, it
        includes all nodes that use inputs with that name, otherwise it
        matches to the fully-qualified name only (i.e. name@format).

        Raises:
            ValueError: if any of the given datasets do not exist in the
                ``Pipeline`` object

        Returns:
            Set of ``Nodes`` that use the given datasets as inputs.
        
Retrieves nodes that use the given `datasets` as inputs.
If provided a name, but no format, for a transcoded dataset, it
includes all nodes that use inputs with that name, otherwise it
matches to the fully-qualified name only .
Retrieves nodes that use the given ` datasets ` as inputs . If provided a name but no format for a transcoded dataset it includes all nodes that use inputs with that name otherwise it matches to the fully - qualified name only .
def _get_nodes_with_inputs_transcode_compatible(
        self, datasets: Set[str]
    ) -> Set[Node]:
        missing = sorted(
            datasets - self.data_sets() - self._transcode_compatible_names()
        )
        if missing:
            raise ValueError(
                "Pipeline does not contain data_sets named {}".format(missing)
            )
        relevant_nodes = set()
        for input_ in datasets:
            if _strip_transcoding(input_) == input_:
                relevant_nodes.update(self._nodes_by_input[_strip_transcoding(input_)])
            else:
                for node_ in self._nodes_by_input[_strip_transcoding(input_)]:
                    if input_ in node_.inputs:
                        relevant_nodes.add(node_)
        return relevant_nodes
def _get_nodes_with_inputs_transcode_compatible ( self , datasets : Set [ str ] ) -> Set [ Node ] : missing = sorted ( datasets - self . data_sets ( ) - self . _transcode_compatible_names ( ) ) if missing : raise ValueError ( "Pipeline does not contain data_sets named {}" . format ( missing ) ) relevant_nodes = set ( ) for input_ in datasets : if _strip_transcoding ( input_ ) == input_ : relevant_nodes . update ( self . _nodes_by_input [ _strip_transcoding ( input_ ) ] ) else : for node_ in self . _nodes_by_input [ _strip_transcoding ( input_ ) ] : if input_ in node_ . inputs : relevant_nodes . add ( node_ ) return relevant_nodes
Retrieves nodes that use the given `datasets` as inputs.
Retrieves nodes that use the given ` datasets ` as inputs .
"""Retrieves nodes that use the given `datasets` as inputs.
        If provided a name, but no format, for a transcoded dataset, it
        includes all nodes that use inputs with that name, otherwise it
        matches to the fully-qualified name only (i.e. name@format).

        Raises:
            ValueError: if any of the given datasets do not exist in the
                ``Pipeline`` object

        Returns:
            Set of ``Nodes`` that use the given datasets as inputs.
        """
Set of ``Nodes`` that use the given datasets as inputs.
Set of ` ` Nodes ` ` that use the given datasets as inputs .
if any of the given datasets do not exist in the
``Pipeline`` object
if any of the given datasets do not exist in the ` ` Pipeline ` ` object
ValueError
self
datasets
Set[str]