(self, max_queue_size: int)
| 269 | |
| 270 | def get_service_status(self) -> Dict[str, Any]: |
| 271 | with self._lock: |
| 272 | active_tasks = [task_id for task_id, task in self._tasks.items() if task.status == TaskStatus.PROCESSING] |
| 273 | |
| 274 | pending_count = sum(1 for t in self._tasks.values() if t.status == TaskStatus.PENDING) |
| 275 | |
| 276 | return { |
| 277 | "service_status": "busy" if self._current_processing_task else "idle", |
| 278 | "current_task": self._current_processing_task, |
| 279 | "active_tasks": active_tasks, |
no test coverage detected