objstorages = {'dst': <swh.objstorage.backends.in_memory.InMemoryObjStorage object at 0x7f90a4a18940>, 'src': <swh.objstorage.backends.in_memory.InMemoryObjStorage object at 0x7f90a4a18908>} kafka_prefix = 'wrzebbtxtc', kafka_consumer_group = 'test-consumer-wrzebbtxtc' kafka_server = '127.0.0.1:50245' caplog = <_pytest.logging.LogCaptureFixture object at 0x7f90a4860860> @_patch_objstorages(["src", "dst"]) def test_replay_content_objnotfound( objstorages, kafka_prefix: str, kafka_consumer_group: str, kafka_server: Tuple[Popen, int], caplog, ): """Check the ContentNotFound is not considered a failure to retry""" contents = _fill_objstorage_and_kafka( kafka_server, kafka_prefix, objstorages["src"] ) # delete a few objects from the src objstorage num_contents_deleted = 5 contents_deleted = set() for i, sha1 in enumerate(contents): if i >= num_contents_deleted: break del objstorages["src"].state[sha1] contents_deleted.add(hash_to_hex(sha1)) caplog.set_level(logging.DEBUG, "swh.objstorage.replayer.replay") result = invoke( "replay", "--stop-after-objects", str(NUM_CONTENTS), journal_config={ "brokers": kafka_server, "group_id": kafka_consumer_group, "prefix": kafka_prefix, }, ) expected = r"Done.\n" > assert result.exit_code == 0, result.output E AssertionError: E assert 1 == 0 E +1 E -0 .tox/py3/lib/python3.7/site-packages/swh/objstorage/replayer/tests/test_cli.py:638: AssertionError