move already post-processed check to post_process_all

Clinical-Genomics · Oct 11, 2024 · a880b6f · a880b6f
1 parent 6a1cf61
commit a880b6f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/cg/services/run_devices/abstract_classes.py b/cg/services/run_devices/abstract_classes.py
@@ -92,6 +92,9 @@ def post_process_all(self, run_directory_names: list[str], dry_run: bool = False
         LOG.info("Starting post-processing for all runs")
         is_post_processing_successful = True
         for run_name in run_directory_names:
+            if self._is_run_post_processed(run_name):
+                LOG.info(f"Run {run_name} has already been post-processed")
+                continue
             try:
                 self.post_process(run_name=run_name, dry_run=dry_run)
             except Exception as error:

diff --git a/cg/services/run_devices/pacbio/post_processing_service.py b/cg/services/run_devices/pacbio/post_processing_service.py
@@ -50,9 +50,6 @@ def __init__(
         to_raise=PostProcessingError,
     )
     def post_process(self, run_name: str, dry_run: bool = False) -> None:
-        if self._is_run_post_processed(run_name):
-            LOG.info(f"Run {run_name} has already been post-processed")
-            return
         LOG.info(f"Starting Pacbio post-processing for run: {run_name}")
         run_data: PacBioRunData = self.run_data_generator.get_run_data(
             run_name=run_name, sequencing_dir=self.sequencing_dir