Skip to content
Snippets Groups Projects
Commit b0ba69df authored by Charlotte Hausman's avatar Charlotte Hausman
Browse files

make workflow recovery acquire correct logfile for DAG jobs

parent 1765a168
No related branches found
No related tags found
1 merge request!883make workflow recovery acquire correct logfile for DAG jobs
Pipeline #4828 passed
......@@ -120,12 +120,14 @@ class MonitorRecover:
return Path(".")
else:
logger.info(f"Searching for log file for Request #{wf_request.workflow_request_id}...")
dag_files = list(results_dir.glob("*.dag"))
if dag_files:
logger.info("Found dagman logfile!")
return Path(str(dag_files[0]) + ".dagman.log")
for root, dirs, files in os.walk(results_dir):
for file in files:
if file.endswith(".dagman.log"):
logger.info("Found dagman logfile!")
return file
elif file.endswith(".log") and (
if file.endswith(".log") and (
file.startswith(wf_request.workflow_name) or file.startswith("condor")
):
logger.info("Found condor logfile!")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment