code: def read_pod_log(namespace, label_selector, release_name):
      init_k8s_client_config()
      items = get_pod_list(namespace, label_selector=label_selector)
  
      try:
          # export log to /tmp/release_name path
          pod_log_path = f"/tmp/milvus_logs/{release_name}"
          if not os.path.isdir(pod_log_path):
              os.makedirs(pod_log_path)
  
          api_instance = client.CoreV1Api()
  
          for item in items:
              pod = item.metadata.name
              log.debug(f"Start to read {pod} log")
              logs = api_instance.read_namespaced_pod_log(
                  name=pod, namespace=namespace, async_req=True
              )
              with open(f"{pod_log_path}/{pod}.log", "w") as f:
                  f.write(logs.get())
  
      except ApiException as e:
          log.error(f"Exception when read pod {pod} logs: %s\n" % e)
          raise Exception(str(e))
  
imports: import json
  import os.path
  import time
  import pyetcd
  import requests
  from pymilvus import connections
  from kubernetes import client, config
  from kubernetes.client.rest import ApiException
  from common.milvus_sys import MilvusSys
  from utils.util_log import test_log
  from chaos import chaos_commons
  from common.common_type import in_cluster_env
label_desc: Use image node_id 10 for calling a global function with example usage: read_pod_log(namespace, label_selector, release_name) without return types