From 8b17ebde8eb78edcaa0a2ddc04182ea3b2594d59 Mon Sep 17 00:00:00 2001 From: Leonardo Schwarz Date: Wed, 4 Sep 2024 17:17:37 +0200 Subject: [PATCH] add todo --- src/depiction_targeted_preproc/pipeline/run_batch.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/depiction_targeted_preproc/pipeline/run_batch.py b/src/depiction_targeted_preproc/pipeline/run_batch.py index 8c5fd40..17df12c 100644 --- a/src/depiction_targeted_preproc/pipeline/run_batch.py +++ b/src/depiction_targeted_preproc/pipeline/run_batch.py @@ -17,6 +17,8 @@ def run_batch(workunit_id: int, work_dir: Path, ssh_user: str | None = None) -> workunit = Workunit.find(id=workunit_id, client=client) batch_dataset = BatchDataset(dataset_id=workunit.input_dataset.id, client=client) + # TODO there is currently a serious bug which prevents the parallelization here, but this would be the place to + # implement it for job in batch_dataset.jobs: run_one_job( client=client,