self = <swh.storage.tests.test_tenacious.TestTenaciousStorage object at 0x7fd9d9fe0668> swh_storage = <swh.storage.proxies.tenacious.TenaciousProxyStorage object at 0x7fd9d9ff7208> sample_data = <swh.storage.tests.storage_data.StorageData object at 0x7fd9d9f54c88> def test_content_add(self, swh_storage, sample_data): cont = sample_data.content insertion_start_time = now() actual_result = swh_storage.content_add([cont]) insertion_end_time = now() assert actual_result == { "content:add": 1, "content:add:bytes": cont.length, } assert swh_storage.content_get_data(cont.sha1) == cont.data expected_cont = attr.evolve(cont, data=None) contents = [ obj for (obj_type, obj) in swh_storage.journal_writer.journal.objects if obj_type == "content" ] assert len(contents) == 1 for obj in contents: assert insertion_start_time <= obj.ctime assert obj.ctime <= insertion_end_time assert obj == expected_cont if not isinstance(swh_storage, (CassandraStorage, RemoteStorage)): swh_storage.refresh_stat_counters() > assert swh_storage.stat_counters()["content"] == 1 .tox/py3/lib/python3.7/site-packages/swh/storage/tests/storage_tests.py:194: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <swh.storage.in_memory.InMemoryStorage object at 0x7fd9d9ff7198> def stat_counters(self): > raise NotImplementedError() E NotImplementedError .tox/py3/lib/python3.7/site-packages/swh/storage/cassandra/storage.py:1293: NotImplementedError