code: def _run_driver(
      executable_spec: Union[
          _PythonClassExecutableSpec, _BeamExecutableSpec
      ],
      mlmd_connection_config: metadata.ConnectionConfigType,
      execution_info: data_types.ExecutionInfo,
  ) -> driver_output_pb2.DriverOutput:
      operator = python_driver_operator.PythonDriverOperator(
          executable_spec, metadata.Metadata(mlmd_connection_config)
      )
      return operator.run_driver(execution_info)
  
file_path: tfx/tfx/orchestration/python_execution_binary/python_execution_lib.py
imports: from typing import Optional, Union
  from absl import logging
  from tfx.dsl.io import fileio
  from tfx.orchestration import metadata
  from tfx.orchestration.portable import data_types
  from tfx.orchestration.portable import python_driver_operator
  from tfx.proto.orchestration import driver_output_pb2
  from tfx.proto.orchestration import executable_spec_pb2
  from tfx.orchestration.python_execution_binary import python_executor_operator_dispatcher
label_desc: Use image node_id 1 for calling a global function with example usage: _run_driver(executable_spec, mlmd_connection_config, execution_info) and returns: operator