fix monitor failure
This commit is contained in:
parent
e23d019f9e
commit
04926c6ccd
@ -606,7 +606,7 @@ class SocketInfo(object):
|
||||
self.more_to_come = reply.more_to_come
|
||||
unpacked_docs = reply.unpack_response()
|
||||
response_doc = unpacked_docs[0]
|
||||
helpers._check_command_response(response_doc)
|
||||
helpers._check_command_response(response_doc, self.max_wire_version)
|
||||
return response_doc
|
||||
|
||||
def command(self, dbname, spec, slave_ok=False,
|
||||
|
||||
@ -334,7 +334,8 @@ class TestIntegration(SpecRunner):
|
||||
|
||||
Assert the given event was published exactly `count` times.
|
||||
"""
|
||||
self.assertEqual(self._event_count(event), count)
|
||||
self.assertEqual(self._event_count(event), count,
|
||||
'expected %s not %r' % (count, event))
|
||||
|
||||
def wait_for_event(self, event, count):
|
||||
"""Run the waitForEvent test operation.
|
||||
|
||||
Loading…
Reference in New Issue
Block a user