From a880b6fd313088fe350d501cd788c28d23e0d5ba Mon Sep 17 00:00:00 2001 From: Sebastian Diaz Date: Fri, 11 Oct 2024 16:25:38 +0200 Subject: [PATCH] move already post-processed check to post_process_all --- cg/services/run_devices/abstract_classes.py | 3 +++ cg/services/run_devices/pacbio/post_processing_service.py | 3 --- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/cg/services/run_devices/abstract_classes.py b/cg/services/run_devices/abstract_classes.py index 0e87349446..ecc8ee571b 100644 --- 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 index 0c8629a89a..6a9946b830 100644 --- 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