def _extract_input_pvalues(self, pvalueish):
    # pylint: disable=g-import-not-at-top
    from google.cloud.dataflow import pipeline
    # pylint: enable=g-import-not-at-top
    if isinstance(pvalueish, pipeline.Pipeline):
      pvalueish = pvalue.PBegin(pvalueish)

    return pvalueish, (pvalueish,)
Extract all the pvalues contained in the input pvalueish.
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/transforms/ptransform.py/PTransform._extract_input_pvalues