diff --git a/swh/journal/tests/test_client.py b/swh/journal/tests/test_client.py --- a/swh/journal/tests/test_client.py +++ b/swh/journal/tests/test_client.py @@ -392,4 +392,6 @@ client.consumer.commit() # Check the first revision has not been passed to worker_fn - worker_fn.assert_called_once_with({"revision": revisions[1:]}) + processed_revisions = set(worker_fn.call_args.args[0]["revision"]) + assert revisions[0] not in processed_revisions + assert all(rev in processed_revisions for rev in revisions[1:])