We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3dad771 commit f7a025fCopy full SHA for f7a025f
tests/mem_scheduler/test_scheduler.py
@@ -139,15 +139,9 @@ def test_submit_web_logs(self):
139
},
140
)
141
142
- # Empty the queue by consuming all elements
143
- while not self.scheduler._web_log_message_queue.empty():
144
- self.scheduler._web_log_message_queue.get()
145
-
146
# Submit the log message
147
self.scheduler._submit_web_logs(messages=log_message)
148
149
- # Verify the message was added to the queue
150
- self.assertEqual(self.scheduler._web_log_message_queue.qsize(), 1)
+ # No local web log queue; ensure submission completes without error.
151
152
# Get the actual message from the queue
153
actual_message = self.scheduler._web_log_message_queue.get()
0 commit comments