sample_data = <swh.storage.tests.storage_data.StorageData object at 0x7fb7f96975f8>
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:386: in skipped_content_add
return self._skipped_content_add(contents)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <swh.storage.in_memory.InMemoryStorage object at 0x7fb7f9697dd8>
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...g', origin='file:///dev/zero', ctime=datetime.datetime(2021, 4, 22, 18, 30, 16, 840443, tzinfo=datetime.timezone.utc))]
def _skipped_content_add(self, contents: List[SkippedContent]) -> Dict:
# Filter-out content already in the database.
> if self._check_missing:
E AttributeError: 'InMemoryStorage' object has no attribute '_check_missing'
.tox/py3/lib/python3.7/site-packages/swh/storage/cassandra/storage.py:360: AttributeError
TEST RESULT
TEST RESULT
- Run At
- Apr 22 2021, 8:33 PM