sample_data = <swh.storage.tests.storage_data.StorageData object at 0x7f3a3cf01518> def test_buffering_proxy_storage_release_deduplicate(sample_data) -> None: releases = sample_data.releases[:2] storage = get_storage_with_buffer_config(min_batch_size={"release": 2,}) s = storage.release_add([releases[0], releases[0]]) assert s == {} s = storage.release_add([releases[0]]) assert s == {} > s = storage.release_add([releases[1]]) .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_buffer.py:394: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ .tox/py3/lib/python3.7/site-packages/swh/storage/buffer.py:138: in object_add return self.flush() .tox/py3/lib/python3.7/site-packages/swh/storage/buffer.py:156: in flush stats = add_fn(list(batch)) _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <swh.storage.in_memory.InMemoryStorage object at 0x7f3a3cf01390> releases = [Release(name=b'v0.0.1', message=b'synthetic release', target=b'\x01\xa7\x11O6\xfd\xdd^\xf2Q\x1b,\xad\xda#zh\xad\xbb\x...=-120, negative_utc=False), metadata=None, id=b'\xdb\x81\xa2g\x83\xa3\xf4\xa9\xdb\x07\xb4u\x9f\xfc7b\x1f\x15\x9b\xb2')] def release_add(self, releases: List[Release]) -> Dict: > if not self._allow_overwrite: E AttributeError: 'InMemoryStorage' object has no attribute '_allow_overwrite' .tox/py3/lib/python3.7/site-packages/swh/storage/cassandra/storage.py:638: AttributeError