diff --git a/shared/workspaces/workspaces/workflow/services/recovery.py b/shared/workspaces/workspaces/workflow/services/recovery.py index f18f63825fbf3a71ec8bf2a55a5fd4a99f80e8d0..6dbaa1c2139c09beb0d1606db5d608c5fdfdd06f 100644 --- a/shared/workspaces/workspaces/workflow/services/recovery.py +++ b/shared/workspaces/workspaces/workflow/services/recovery.py @@ -137,6 +137,7 @@ class MonitorRecover: f"Results directory {results_dir} for request #{wf_request.workflow_request_id} " f"is not a directory! Skipping." ) + # signal not a directory with current location return Path(".") @staticmethod @@ -148,7 +149,8 @@ class MonitorRecover: :param wf_request: The WorkflowRequest to update :return: """ - if logfile == Path.cwd(): + # because for some reason these are not the same.... + if logfile == Path.cwd() or logfile == Path("."): return logger.info("Running wf_monitor.")