diff --git a/apps/cli/utilities/wf_monitor/wf_monitor/monitor.py b/apps/cli/utilities/wf_monitor/wf_monitor/monitor.py
index 8bd65fd6d56c31e9225d0fee1abf438787ef72c6..ffbe8197c35b914f07bd159ce0bdac3ee36fad69 100644
--- a/apps/cli/utilities/wf_monitor/wf_monitor/monitor.py
+++ b/apps/cli/utilities/wf_monitor/wf_monitor/monitor.py
@@ -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}"