sample_data = <swh.storage.tests.storage_data.StorageData object at 0x7fab02ddd860> def test_buffering_proxy_storage_release_threshold_not_hit(sample_data) -> None: releases = sample_data.releases threshold = 10 assert len(releases) < threshold storage = get_storage_with_buffer_config( min_batch_size={"release": threshold,} # configuration set ) s = storage.release_add(releases) assert s == {} release_ids = [r.id for r in releases] missing_releases = storage.release_missing(release_ids) assert list(missing_releases) == release_ids > s = storage.flush() .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_buffer.py:353: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ .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 0x7fab02ddd208> 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...seconds=0), offset=-120, negative_utc=False), metadata=None, id=b">\x90P\x19j\xa2\x88&O*\x9d'\x9dj\xba\xb8\xb1XD\x8b")] def release_add(self, releases: List[Release]) -> Dict: > 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:635: AttributeError