(self)
| 415 | |
| 416 | class StreamingJobManager: |
| 417 | def __init__(self) -> None: |
| 418 | self._lock = threading.Lock() |
| 419 | self._jobs: dict[str, StreamingJob] = {} |
| 420 | |
| 421 | def create(self) -> StreamingJob: |
| 422 | stream_id = f"stream-{int(time.time() * 1000)}-{uuid.uuid4().hex[:8]}" |
nothing calls this directly
no outgoing calls
no test coverage detected