diff --git a/dataflow_transfer/dataflow_transfer.py b/dataflow_transfer/dataflow_transfer.py index 3b34bb7..ebbae9c 100644 --- a/dataflow_transfer/dataflow_transfer.py +++ b/dataflow_transfer/dataflow_transfer.py @@ -22,8 +22,9 @@ def process_run(run_dir, sequencer, config): run.confirm_run_type() ## Transfer already completed. Do nothing. - if run.final_sync_successful: - # Removing the exit code file lets the run retry transfer + if run.final_sync_successful and run.has_status("transferred_to_hpc"): + # Check transfer success both in statusdb and via exit code file + # To restart transfer, remove the exit code file logger.info(f"Transfer of {run_dir} is finished. No action needed.") return diff --git a/pyproject.toml b/pyproject.toml index 157624c..88ed6df 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -20,7 +20,7 @@ ignore = [ [project] name = "dataflow_transfer" -version = "1.0.3" +version = "1.0.4" description = "Script for transferring sequencing data from sequencers to storage" authors = [ { name = "Sara Sjunnebo", email = "sara.sjunnebo@scilifelab.se" },