Skip to content

Commit d67fdd6

Browse files
committed
changes to job manager
1 parent 246ac2f commit d67fdd6

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

openeo/extra/job_management/_manager.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -811,6 +811,7 @@ def _cancel_prolonged_job(self, job: BatchJob, row):
811811
except Exception as e:
812812
_log.error(f"Unexpected error while handling job {job.job_id}: {e}")
813813

814+
#TODO pull this functionality away from the manager to a general utility class? job dir creation could be reused for tje Jobdownload task
814815
def get_job_dir(self, job_id: str) -> Path:
815816
"""Path to directory where job metadata, results and error logs are be saved."""
816817
return self._root_dir / f"job_{job_id}"

openeo/extra/job_management/_thread_worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ def execute(self) -> _TaskResult:
173173
return _TaskResult(
174174
job_id=self.job_id,
175175
df_idx=self.df_idx,
176-
db_update={}, #TODO consider db updates
176+
db_update={}, #TODO consider db updates?
177177
stats_update={"job download": 1},
178178
)
179179
except Exception as e:

0 commit comments

Comments
 (0)