replayer_storage_and_client = (<swh.storage.in_memory.InMemoryStorage object at 0x7f6a5f8d4ba8>, <swh.journal.client.JournalClient object at 0x7f6a5f8d49e8>) caplog = <_pytest.logging.LogCaptureFixture object at 0x7f6a5f91e898> def test_storage_play_with_collision(replayer_storage_and_client, caplog): """Another replayer scenario with collisions. This: - writes objects to the topic, including colliding contents - replayer consumes objects from the topic and replay them - This drops the colliding contents from the replay when detected """ src, replayer = replayer_storage_and_client # Fill Kafka using a source storage nb_sent = 0 for object_type, objects in TEST_OBJECTS.items(): if object_type == "origin_visit": for visit in objects: src.origin_visit_add( > origin_url=visit.origin, date=visit.date, type=visit.type ) E TypeError: origin_visit_add() got an unexpected keyword argument 'origin_url' .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_replay.py:121: TypeError