(self)
| 1112 | # ─── worker thread (runs query() turns) ──────────────────────────────── |
| 1113 | |
| 1114 | def start(self) -> None: |
| 1115 | self._worker = threading.Thread( |
| 1116 | target=self._run_worker, |
| 1117 | name=f"agent-server-{self.session_id}", |
| 1118 | daemon=True, |
| 1119 | ) |
| 1120 | self._worker.start() |
| 1121 | |
| 1122 | def _run_worker(self) -> None: |
| 1123 | while not self._stop.is_set(): |
no outgoing calls
no test coverage detected