Skip to content

Commit e2b6ab8

Browse files
committed
working on fix for indefinete loop
1 parent 855a393 commit e2b6ab8

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

openeo/extra/job_management/_manager.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -534,9 +534,11 @@ def run_jobs(
534534

535535
if self._worker_pool is not None:
536536
self._worker_pool.shutdown()
537+
self._worker_pool = None
537538

538539
if self._download_pool is not None:
539540
self._download_pool.shutdown()
541+
self._download_pool = None
540542

541543
return stats
542544

@@ -751,7 +753,6 @@ def on_job_done(self, job: BatchJob, row):
751753
:param job: The job that has finished.
752754
:param row: DataFrame row containing the job's metadata.
753755
"""
754-
# TODO: param `row` is never accessed in this method. Remove it? Is this intended for future use?
755756
if self._download_results:
756757

757758
job_dir = self.get_job_dir(job.job_id)

0 commit comments

Comments
 (0)