self = <swh.storage.tests.test_tenacious.TestTenaciousStorage object at 0x7fd9db9d1358> swh_storage = <swh.storage.proxies.tenacious.TenaciousProxyStorage object at 0x7fd9db9d1860> sample_data = <swh.storage.tests.storage_data.StorageData object at 0x7fd9db9d2e48> def test_release_add(self, swh_storage, sample_data): release, release2 = sample_data.releases[:2] init_missing = swh_storage.release_missing([release.id, release2.id]) assert list(init_missing) == [release.id, release2.id] actual_result = swh_storage.release_add([release, release2]) assert actual_result == {"release:add": 2} end_missing = swh_storage.release_missing([release.id, release2.id]) assert list(end_missing) == [] assert list(swh_storage.journal_writer.journal.objects) == [ ("release", release), ("release", release2), ] # already present so nothing added actual_result = swh_storage.release_add([release, release2]) assert actual_result == {"release:add": 0} if not isinstance(swh_storage, (CassandraStorage, RemoteStorage)): swh_storage.refresh_stat_counters() > assert swh_storage.stat_counters()["release"] == 2 .tox/py3/lib/python3.7/site-packages/swh/storage/tests/storage_tests.py:1387: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <swh.storage.in_memory.InMemoryStorage object at 0x7fd9db9d1fd0> def stat_counters(self): > raise NotImplementedError() E NotImplementedError .tox/py3/lib/python3.7/site-packages/swh/storage/cassandra/storage.py:1293: NotImplementedError