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,