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

Merge branch 'fix-wf-monitor' into '2.8.3.1-patch'

force monitor closure to wait for final messages to clear

See merge request !1672
parents 41ae2dc5 171af785
No related branches found
No related tags found
3 merge requests!1687Pickup patch changes,!1685merge patch to main,!1672force monitor closure to wait for final messages to clear
......@@ -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}"
......
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