def __ror__(self, left):
    pvalueish, pvalues = self._extract_input_pvalues(left)
    pipelines = [v.pipeline for v in pvalues if isinstance(v, pvalue.PValue)]
    if pvalues and not pipelines:
      deferred = False
      # pylint: disable=g-import-not-at-top
      from google.cloud.dataflow import pipeline
      from google.cloud.dataflow.utils.options import PipelineOptions
      # pylint: enable=g-import-not-at-top
      p = pipeline.Pipeline(
          'DirectPipelineRunner', PipelineOptions(sys.argv))
    else:
      deferred = True
      if not pipelines:
        if self.pipeline is not None:
          p = self.pipeline
        else:
          raise ValueError('"%s" requires a pipeline to be specified '
                           'as there are no deferred inputs.'% self.label)
      else:
        p = self.pipeline or pipelines[0]
        for pp in pipelines:
          if p != pp:
            raise ValueError(
                'Mixing value from different pipelines not allowed.')
    # pylint: disable=g-import-not-at-top
    from google.cloud.dataflow.transforms.core import Create
    # pylint: enable=g-import-not-at-top
    replacements = {id(v): p | Create('CreatePInput%s' % ix, v)
                    for ix, v in enumerate(pvalues)
                    if not isinstance(v, pvalue.PValue) and v is not None}
    pvalueish = _SetInputPValues().visit(pvalueish, replacements)
    self.pipeline = p
    result = p.apply(self, pvalueish)
    if deferred:
      return result
    else:
      p.run()
      return _MaterializePValues().visit(result)
Generate Alembic operations for the ALTER TABLE ... DROP CONSTRAINT
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/transforms/ptransform.py/PTransform.__ror__--crossover with--dataset/ETHPy150Open goFrendiAsgard/kokoropy/kokoropy/packages/alembic/autogenerate/render.py/_drop_constraint