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:
      # TODO(robertwb): Handle type hints for multi-output transforms.
      return transform_node.outputs[0].element_type
    else:
      # TODO(silviuc): Remove this branch (and assert) when typehints are
      # propagated everywhere. Returning an 'Any' as type hint will trigger
      # usage of the fallback coder (i.e., cPickler).
      return typehints.Any
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py/DataflowPipelineRunner._get_transform_type_hint/original