Skip to content
Snippets Groups Projects

make sure restarted workflows restart dag monitoring properly

Merged Charlotte Hausman requested to merge fix_progress_for_restarts into main
1 file
+ 2
2
Compare changes
  • Side-by-side
  • Inline
@@ -22,7 +22,6 @@ Workspaces Workflow Service - Workflow Recovery Facility
import logging
import os
import pathlib
import subprocess
from pathlib import Path
from typing import List
@@ -155,8 +154,9 @@ class MonitorRecover:
return
logger.info("Running wf_monitor.")
is_dag = True if str(logfile).endswith(".dagman.log") else False
WorkflowMonitor(logfile, wf_request).start()
WorkflowMonitor(logfile, wf_request, is_dag).start()
logger.info(f"Successfully reacquired monitor for request #{wf_request.workflow_request_id}. Continuing...")
def reacquire_inflight_requests(self):
Loading