kedro/pipeline/pipeline.py
def _get_nodes_with_outputs_transcode_compatible(
        self, datasets: Set[str]
    ) -> Set[Node]:
        """Retrieves nodes that output to the given `datasets`.
        If provided a name, but no format, for a transcoded dataset, it
        includes the node that outputs to 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 output to the given datasets.
        """
        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 output in datasets:
            if _strip_transcoding(output) in self._nodes_by_output:
                node_with_output = self._nodes_by_output[_strip_transcoding(output)]
                if (
                    _strip_transcoding(output) == output
                    or output in node_with_output.outputs
                ):
                    relevant_nodes.add(node_with_output)

        return relevant_nodes
Retrieves nodes that output to the given `datasets`.
        If provided a name, but no format, for a transcoded dataset, it
        includes the node that outputs to 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 output to the given datasets.
        
Retrieves nodes that output to the given `datasets`.
If provided a name, but no format, for a transcoded dataset, it
includes the node that outputs to that name, otherwise it matches
to the fully-qualified name only .
Retrieves nodes that output to the given ` datasets ` . If provided a name but no format for a transcoded dataset it includes the node that outputs to that name otherwise it matches to the fully - qualified name only .
def _get_nodes_with_outputs_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 output in datasets:
            if _strip_transcoding(output) in self._nodes_by_output:
                node_with_output = self._nodes_by_output[_strip_transcoding(output)]
                if (
                    _strip_transcoding(output) == output
                    or output in node_with_output.outputs
                ):
                    relevant_nodes.add(node_with_output)
        return relevant_nodes
def _get_nodes_with_outputs_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 output in datasets : if _strip_transcoding ( output ) in self . _nodes_by_output : node_with_output = self . _nodes_by_output [ _strip_transcoding ( output ) ] if ( _strip_transcoding ( output ) == output or output in node_with_output . outputs ) : relevant_nodes . add ( node_with_output ) return relevant_nodes
Retrieves nodes that output to the given `datasets`.
Retrieves nodes that output to the given ` datasets ` .
"""Retrieves nodes that output to the given `datasets`.
        If provided a name, but no format, for a transcoded dataset, it
        includes the node that outputs to 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 output to the given datasets.
        """
Set of ``Nodes`` that output to the given datasets.
Set of ` ` Nodes ` ` that output to the given datasets .
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]