

def _get_transform_type_hint(self, transform_node):
    'Returns the typehint for a applied transform node or a default.'
    if (transform_node.outputs[0].element_type is not None):
        return transform_node.outputs[0].element_type
    else:
        return typehints.Any

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py DataflowPipelineRunner._get_transform_type_hint/original