class_docstr: Synchronous abstraction for tracking requests.
class_docstr_tok: ["Synchronous","abstraction","for","tracking","requests","."]
docstr: Propagate an exception to request streams
  (all if request_id is None).
docstr_tok: ["Propagate","an","exception","to","request","streams","(","all","if","request_id","is","None",")","."]
code: def propagate_exception(
      self, exc: Exception, request_id: Optional[str] = None
  ) -> None:
      """Propagate an exception to request streams
      (all if request_id is None)."""
      if request_id is not None:
          self._request_streams[request_id].put(exc)
      else:
          for stream in self._request_streams.values():
              stream.put(exc)
  
imports: import asyncio
  import time
  from functools import partial
  from typing import Any, Dict, Iterable, List, Optional, Set, Tuple, Type, Union
  from bigdl.llm.vllm.config import ModelConfig
  from bigdl.llm.vllm.engine.arg_utils import AsyncEngineArgs
  from bigdl.llm.vllm.engine.llm_engine import LLMEngine
  from bigdl.llm.vllm.logger import init_logger
  from bigdl.llm.vllm.outputs import RequestOutput
  from bigdl.llm.vllm.sampling_params import SamplingParams
  from bigdl.llm.utils.common import invalidInputError
label_desc: Use image node_id 4 for calling the RequestTracker obj's underlying member method code with example usage: obj.propagate_exception(exc, request_id) without return types