make sure restarted workflows restart dag monitoring properly

shared/workspaces/workspaces/workflow/services/recovery.py

@@ -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):