Skip to content
Snippets Groups Projects
Commit 79d28b51 authored by David Douard's avatar David Douard
Browse files

Make the test_client_with_deserializer reliable

hopefully
parent f92d4acf
No related branches found
No related tags found
No related merge requests found
......@@ -368,5 +368,10 @@ def test_client_with_deserializer(
)
worker_fn = MagicMock()
client.process(worker_fn)
# check that the first Revision has not been passed to worker_fn
# a commit seems to be needed to prevent some race condition situation
# where the worker_fn has not yet been called at this point (not sure how)
client.consumer.commit()
# Check the first revision has not been passed to worker_fn
worker_fn.assert_called_once_with({"revision": revisions[1:]})
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