Skip to content
Snippets Groups Projects

force monitor closure to wait for final messages to clear

Merged Charlotte Hausman requested to merge fix-wf-monitor into 2.8.3.1-patch
1 unresolved thread
1 file
+ 3
0
Compare changes
  • Side-by-side
  • Inline
@@ -550,7 +550,10 @@ class WorkflowMonitor:
return WorkflowStatusMessages.COMPLETE.value if return_value == 0 else WorkflowStatusMessages.FAILED.value
def close(self):
logger.info("Waiting 3 seconds for final messages to clear....")
time.sleep(3)
self.message_router.close()
logger.info(f"Monitor closed for {self.workflow_request_id}")
def __str__(self):
return f"WorkflowMonitor, monitoring {self.logfile_path} that has events {self.events}"
Loading