code: def mock_event_streams(monkeypatch):
      """Patches the kubernetes event stream with a mock and returns it."""
      job_stream = MockEventStream()
      pod_stream = MockEventStream()
  
      def _select_stream(_, api_call, *args, **kwargs):
          if api_call.__name__ == "list_namespaced_pod":
              return pod_stream
          elif api_call.__name__ == "list_namespaced_job":
              return job_stream
          elif api_call.__name__ == "list_namespaced_custom_object":
              return job_stream
          raise Exception(
              f"Event stream requested for unsupported API call: {api_call.__name__} "
          )
  
      monkeypatch.setattr(
          "wandb.sdk.launch.runner.kubernetes_monitor.SafeWatch.stream",
          _select_stream,
      )
      return job_stream, pod_stream
  
imports: import asyncio
  import base64
  import json
  from typing import Any
  from unittest.mock import MagicMock
  import pytest
  import wandb
  from kubernetes_asyncio.client import ApiException
  from wandb.sdk.launch._project_spec import LaunchProject
  from wandb.sdk.launch.errors import LaunchError
  from wandb.sdk.launch.runner.kubernetes_monitor import CustomResource, LaunchKubernetesMonitor, _is_container_creating, _log_err_task_callback, _state_from_conditions, _state_from_replicated_status
  from wandb.sdk.launch.runner.kubernetes_runner import KubernetesRunner, KubernetesSubmittedRun, add_entrypoint_args_overrides, add_label_to_pods, add_wandb_env, maybe_create_imagepull_secret
label_desc: Use image node_id 7 for calling a global function with example usage: mock_event_streams(monkeypatch) and returns: job_stream,  pod_stream, pod_stream, job_stream, job_stream