code: def main(unused_argv):
      logging.set_verbosity(logging.INFO)
      execution_info = _prepare_sample_execution_info(
          FLAGS.storage_bucket,
          "/artifact-output",
          "/test-output",
          "/data/schema.pbtxt",
      )
      executable_spec = _prepare_sample_executable_spec()
  
      runner = kubernetes_job_runner.KubernetesJobRunner(
          tfx_image=FLAGS.docker_image,
          job_prefix=FLAGS.job_prefix,
          container_name=FLAGS.container_name,
      )
      _ = runner.run(
          execution_info=execution_info, executable_spec=executable_spec
      )
  
file_path: tfx/tfx/orchestration/experimental/centralized_kubernetes_orchestrator/examples/run_sample_component.py
imports: from absl import app
  from absl import flags
  from absl import logging
  from tfx import v1
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator import kubernetes_job_runner
  from tfx.orchestration.portable import data_types
  from tfx.proto.orchestration import pipeline_pb2
  from google.protobuf import text_format
label_desc: Use image node_id 3 for calling a global function with example usage: main(unused_argv) without return types