Main worker loop.
(self)
| 148 | print(f"Error saving job statuses: {e}") |
| 149 | |
| 150 | def _worker_loop(self): |
| 151 | """Main worker loop.""" |
| 152 | while self.running: |
| 153 | try: |
| 154 | if not self.processing_queue.empty(): |
| 155 | job_id = self.processing_queue.get(timeout=1) |
| 156 | self._process_job(job_id) |
| 157 | else: |
| 158 | time.sleep(1) |
| 159 | except Exception as e: |
| 160 | print(f"Worker error: {e}") |
| 161 | time.sleep(1) |
| 162 | |
| 163 | def _process_job(self, job_id: str): |
| 164 | """Process a single documentation generation job.""" |
nothing calls this directly
no test coverage detected