def _add_pvalue(self, pval):
    if pval not in self._nodes:
      self._nodes.append(pval)
Adds a PValue to the pipeline's node list.
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/pipeline.py/Pipeline._add_pvalue