We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8ccb442 commit 855a393Copy full SHA for 855a393
openeo/extra/job_management/_manager.py
@@ -395,16 +395,12 @@ def stop_job_thread(self, timeout_seconds: Optional[float] = _UNSET):
395
if self._worker_pool is not None:
396
self._worker_pool.shutdown()
397
self._worker_pool = None
398
-
399
- if self._download_pool is not None:
400
- self._download_pool.shutdown()
401
- self._download_pool = None
402
403
if self._download_pool is not None:
404
# Wait for downloads to complete before shutting down
405
_log.info("Waiting for download tasks to complete before stopping...")
406
while self._download_pool.num_pending_tasks() > 0:
407
- time.sleep(0.5)
+ time.sleep(1)
408
self._download_pool.shutdown()
409
self._download_pool = None
410
0 commit comments