From 45f28bac1448ec9e6cb347e6eedd585252aea1f3 Mon Sep 17 00:00:00 2001
From: Nate Coraor <nate@bx.psu.edu>
Date: Fri, 23 Sep 2022 10:46:59 -0400
Subject: [PATCH] Fix recovering "lost" jobs where the job directory does not
exist at startup/recovery time
---
pulsar/managers/staging/post.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/pulsar/managers/staging/post.py b/pulsar/managers/staging/post.py
index 2fe6d06f..ebe4bc6a 100644
--- a/pulsar/managers/staging/post.py
+++ b/pulsar/managers/staging/post.py
@@ -44,6 +44,9 @@ def __collect_outputs(job_directory, staging_config, action_executor):
def realized_dynamic_file_sources(job_directory):
launch_config = job_directory.load_metadata("launch_config")
+ if launch_config is None:
+ log.warning(f"Failed to load launch_config from: {job_directory.job_directory}")
+ return []
dynamic_file_sources = launch_config.get("dynamic_file_sources")
realized_dynamic_file_sources = []
for dynamic_file_source in (dynamic_file_sources or []):
--
GitLab