(self, stream: str, line: str)
| 80 | self.queue.put({"event": event, "data": data}) |
| 81 | |
| 82 | def write_log(self, stream: str, line: str) -> None: |
| 83 | with self.log_lock: |
| 84 | with open(self.log_path, "a", encoding="utf-8") as handle: |
| 85 | handle.write(f"[{stream}] {line}\n") |
| 86 | |
| 87 | |
| 88 | class RunRequest(BaseModel): |