swh_storage_backend_config = {'check_config': {'check_write': True}, 'cls': 'local', 'db': "dbname=storage user=postgres host=127.0.0.1 port=16873 ...riter': {'brokers': ['127.0.0.1:41371'], 'client_id': 'kafka_writer-1', 'cls': 'kafka', 'prefix': 'muhacqhoos-1'}, ...} kafka_prefix = 'muhacqhoos', kafka_consumer_group = 'test-consumer-muhacqhoos' kafka_server = '127.0.0.1:41371' @patch("swh.storage.backfill.RANGE_GENERATORS", RANGE_GENERATORS) def test_backfiller( swh_storage_backend_config, kafka_prefix: str, kafka_consumer_group: str, kafka_server: str, ): prefix1 = f"{kafka_prefix}-1" prefix2 = f"{kafka_prefix}-2" journal1 = { "cls": "kafka", "brokers": [kafka_server], "client_id": "kafka_writer-1", "prefix": prefix1, } swh_storage_backend_config["journal_writer"] = journal1 storage = get_storage(**swh_storage_backend_config) # fill the storage and the journal (under prefix1) for object_type, objects in TEST_OBJECTS.items(): > method = getattr(storage, object_type + "_add") E AttributeError: 'Storage' object has no attribute 'extid_add' .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_backfill.py:205: AttributeError