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

force monitor closure to wait for final messages to clear

parent 41ae2dc5
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
Pipeline #15941 passed
......@@ -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