class_docstr: A Kubernetes job runner that launches and executes pipeline components in kubernetes cluster.
docstr: Stream logs from orchestrator pod.
docstr_tok: ["Stream","logs","from","orchestrator","pod","."]
code: def _stream_logs(self) -> None:
      """Stream logs from orchestrator pod."""
      logging.info(
          "Start log streaming for pod %s:%s.",
          self._namespace,
          self._pod_name,
      )
      logs = self._k8s_core_api.read_namespaced_pod_log(
          name=self._pod_name,
          namespace="default",
          container=self._container_name,
          follow=True,
          _preload_content=False,
      ).stream()
      for log in logs:
          logging.info(log.decode().rstrip("\n"))
  
imports: import abc
  import datetime
  import random
  import string
  import time
  from absl import logging
  from kubernetes import client
  from tfx.orchestration.experimental.core import task_scheduler
  from tfx.orchestration.python_execution_binary import python_execution_binary_utils
  from tfx.utils import kube_utils
  from tfx.utils import status
label_desc: Use image node_id 5 for calling the KubernetesJobRunner obj's underlying member method code with example usage: obj._stream_logs() without return types