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