code: def main(unused_argv):
      prefix = f"gs://{_STORAGE_BUCKET.value}"
      sample_pipeline = pipeline.Pipeline(
          pipeline_name=_PIPELINE_NAME.value,
          pipeline_root=prefix + "/tfx/pipelines",
          components=[
              tfx.components.ImportSchemaGen(
                  prefix + "/data/schema.pbtxt"
              )
          ],
          enable_cache=False,
      )
      pipeline_ir = compiler.Compiler().compile(sample_pipeline)
      runtime_parameter_utils.substitute_runtime_parameter(
          pipeline_ir,
          {
              constants.PIPELINE_RUN_ID_PARAMETER_NAME: datetime.datetime.now().isoformat(),
          },
      )
  
      channel_creds = grpc.local_channel_credentials()
      with grpc.secure_channel(
          _SERVER_ADDRESS.value, channel_creds
      ) as channel:
          grpc.channel_ready_future(channel).result()
          stub = service_pb2_grpc.KubernetesOrchestratorStub(channel)
          request = service_pb2.StartPipelineRequest(
              pipeline=pipeline_ir
          )
          stub.StartPipeline(request)
  
file_path: tfx/tfx/orchestration/experimental/centralized_kubernetes_orchestrator/examples/run_sample_pipeline.py
imports: import datetime
  from absl import app
  from absl import flags
  import grpc
  from tfx import v1
  from tfx.dsl.compiler import compiler
  from tfx.dsl.compiler import constants
  from tfx.orchestration import pipeline
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service.proto import service_pb2
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service.proto import service_pb2_grpc
  from tfx.orchestration.portable import runtime_parameter_utils
label_desc: Use image node_id 1 for calling a global function with example usage: main(unused_argv) without return types