(self)
| 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]}" |
| 423 | job = StreamingJob(stream_id=stream_id) |
| 424 | with self._lock: |
| 425 | self._jobs[stream_id] = job |
| 426 | return job |
| 427 | |
| 428 | def get(self, stream_id: str) -> StreamingJob | None: |
| 429 | with self._lock: |
no test coverage detected