sample_data = <swh.storage.tests.storage_data.StorageData object at 0x7f3a3bd773c8>
def test_buffering_proxy_storage_skipped_content_threshold_nb_hit(sample_data) -> None:
contents = sample_data.skipped_contents
storage = get_storage_with_buffer_config(min_batch_size={"skipped_content": 1,})
> s = storage.skipped_content_add([contents[0]])
.tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_buffer.py:132:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.tox/py3/lib/python3.7/site-packages/swh/storage/buffer.py:119: in skipped_content_add
keys=["sha1", "sha1_git", "sha256", "blake2s256"],
.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))
.tox/py3/lib/python3.7/site-packages/swh/storage/cassandra/storage.py:389: in skipped_content_add
return self._skipped_content_add(contents)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <swh.storage.in_memory.InMemoryStorage object at 0x7f3a3bd77278>
contents = [SkippedContent(sha1=b'C\xe4]V\xf8\x89\x93\xaa\xe6\xa0\x19\x80\x13\xef\xa8\x07\x16\xfd\x89 ', sha1_git=b'3\xe4]V\xf8\x...ng', origin='file:///dev/zero', ctime=datetime.datetime(2021, 4, 29, 8, 20, 15, 492360, tzinfo=datetime.timezone.utc))]
def _skipped_content_add(self, contents: List[SkippedContent]) -> Dict:
# Filter-out content already in the database.
> 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:363: AttributeError
TEST RESULT
TEST RESULT
- Run At
- Apr 29 2021, 10:23 AM