kafka_prefix = 'hsztdsxihy', kafka_consumer_group = 'test-consumer-hsztdsxihy' kafka_server = '127.0.0.1:41371', privileged = True @pytest.mark.parametrize("privileged", [True, False]) def test_storage_play_anonymized( kafka_prefix: str, kafka_consumer_group: str, kafka_server: str, privileged: bool, ): """Optimal replayer scenario. This: - writes objects to the topic - replayer consumes objects from the topic and replay them This tests the behavior with both a privileged and non-privileged replayer """ writer_config = { "cls": "kafka", "brokers": [kafka_server], "client_id": "kafka_writer", "prefix": kafka_prefix, "anonymize": True, } src_config: Dict[str, Any] = {"cls": "memory", "journal_writer": writer_config} storage = get_storage(**src_config) # Fill the src storage nb_sent = 0 for obj_type, objs in TEST_OBJECTS.items(): if obj_type in ("origin_visit", "origin_visit_status"): # these are unrelated with what we want to test here continue > method = getattr(storage, obj_type + "_add") E AttributeError: 'InMemoryStorage' object has no attribute 'extid_add' .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_replay.py:301: AttributeError