There was an error while loading. Please reload this page.
1 parent 677b9c8 commit b12d6b7Copy full SHA for b12d6b7
test/test_command_monitoring_spec.py
@@ -122,9 +122,13 @@ def run_scenario(self):
122
if 'limit' in args and client_context.version[:2] < (3, 1):
123
self.client._kill_cursors_executor.wake()
124
started = self.listener.results['started']
125
+ succeeded = self.listener.results['succeeded']
126
wait_until(
127
lambda: started[-1].command_name == 'killCursors',
128
"publish a start event for killCursors.")
129
+ wait_until(
130
+ lambda: succeeded[-1].command_name == 'killCursors',
131
+ "publish a succeeded event for killCursors.")
132
else:
133
try:
134
getattr(coll, name)(**args)
0 commit comments