code: def main():
      # Log to the container's stdout so it can be streamed by the client.
      logging.basicConfig(stream=sys.stdout, level=logging.INFO)
      logging.getLogger().setLevel(logging.INFO)
  
      parser = argparse.ArgumentParser()
  
      # Pipeline is serialized via a json format.
      # See kubernetes_remote_runner._serialize_pipeline for details.
      parser.add_argument(
          "--serialized_pipeline", type=str, required=True
      )
      parser.add_argument("--tfx_image", type=str, required=True)
      args = parser.parse_args()
  
      kubernetes_dag_runner.KubernetesDagRunner(
          config=kubernetes_dag_runner.KubernetesDagRunnerConfig(
              tfx_image=args.tfx_image
          )
      ).run(
          kubernetes_remote_runner.deserialize_pipeline(
              args.serialized_pipeline
          )
      )
  
imports: import argparse
  import logging
  import sys
  from tfx.orchestration.experimental.kubernetes import kubernetes_dag_runner
  from tfx.orchestration.experimental.kubernetes import kubernetes_remote_runner
label_desc: Use image node_id 1 for calling a global function with example usage: main() without return types