def _current_transform(self):
    return self.transforms_stack[-1]
Returns the transform currently on the top of the stack.
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/pipeline.py/Pipeline._current_transform