(self)
| 171 | self.stop_processing.set() |
| 172 | if self.processing_thread and self.processing_thread.is_alive(): |
| 173 | self.processing_thread.join(timeout=5) |
| 174 | |
| 175 | services = get_services() |
| 176 | if services.file_service: |
| 177 | await services.file_service.cleanup() |