diff --git a/taca/analysis/analysis_element.py b/taca/analysis/analysis_element.py index 0f20ba8a..e57052a6 100755 --- a/taca/analysis/analysis_element.py +++ b/taca/analysis/analysis_element.py @@ -88,7 +88,7 @@ def _process(run): run.update_statusdb() logger.info(f"{run} is being transferred. Skipping.") return - elif transfer_status == "finished": + elif transfer_status == "rsync done": if run.rsync_success(): run.remove_transfer_indicator() run.update_transfer_log() diff --git a/taca/element/Element_Runs.py b/taca/element/Element_Runs.py index bd807b52..5267d6ba 100644 --- a/taca/element/Element_Runs.py +++ b/taca/element/Element_Runs.py @@ -392,7 +392,7 @@ def get_transfer_status(self): elif self.transfer_ongoing() and not self.rsync_complete(): return "ongoing" elif self.rsync_complete() and not self.in_transfer_log(): - return "finished" + return "rsync done" elif self.in_transfer_log(): return "unknown"