replayer_storage_and_client = (<swh.storage.in_memory.InMemoryStorage object at 0x7f3845cbf278>, <swh.journal.client.JournalClient object at 0x7f3845cbfba8>) def test_replay_skipped_content_bwcompat(replayer_storage_and_client): """Test the 'content' topic can be used to replay SkippedContent objects.""" src, replayer = replayer_storage_and_client > _check_replay_skipped_content(src, replayer, "content") .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_replay.py:213: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_replay.py:288: in _check_replay_skipped_content nb_inserted = replayer.process(worker_fn) .tox/py3/lib/python3.7/site-packages/swh/journal/client.py:265: in process batch_processed, at_eof = self.handle_messages(messages, worker_fn) .tox/py3/lib/python3.7/site-packages/swh/journal/client.py:292: in handle_messages worker_fn(dict(objects)) .tox/py3/lib/python3.7/site-packages/swh/storage/replay.py:62: in process_replay_objects _insert_objects(object_type, objects, storage) .tox/py3/lib/python3.7/site-packages/swh/storage/replay.py:132: in _insert_objects collision_aware_content_add(storage.skipped_content_add, skipped_contents) .tox/py3/lib/python3.7/site-packages/swh/storage/replay.py:86: in collision_aware_content_add content_add_fn(contents) .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 0x7f384ea6f400> contents = [SkippedContent(sha1=b':\xf8E\xc4\xffT\xc1\x11/c>=l\xe3k\xf98\xb1&\xf4', sha1_git=b'\x14\xaa\x17E\x94\x17\xc6<\xda^E1\...in='https://somewhere/19', ctime=datetime.datetime(2021, 4, 29, 8, 22, 55, 603071, 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