kafka_prefix = 'spgjmbwrev', kafka_server = '127.0.0.1:41371' consumer = <cimpl.Consumer object at 0x7f56dfc32400> def test_storage_direct_writer(kafka_prefix: str, kafka_server, consumer: Consumer): writer_config = { "cls": "kafka", "brokers": [kafka_server], "client_id": "kafka_writer", "prefix": kafka_prefix, "anonymize": False, } storage_config: Dict[str, Any] = { "cls": "pipeline", "steps": [{"cls": "memory", "journal_writer": writer_config},], } storage = get_storage(**storage_config) expected_messages = 0 for obj_type, objs in TEST_OBJECTS.items(): > 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_kafka_writer.py:39: AttributeError