(self, stream_id: str)
| 444 | return job |
| 445 | |
| 446 | def delete(self, stream_id: str) -> StreamingJob | None: |
| 447 | with self._lock: |
| 448 | return self._jobs.pop(stream_id, None) |
| 449 | |
| 450 | |
| 451 | def _warmup_status_text(snapshot: WarmupSnapshot) -> str: |
no outgoing calls
no test coverage detected