objstorages = {'dst': <swh.objstorage.backends.in_memory.InMemoryObjStorage object at 0x7f90a4a18390>, 'src': <swh.objstorage.backends.in_memory.InMemoryObjStorage object at 0x7f90a4a181d0>}
kafka_prefix = 'izvczznrro', kafka_consumer_group = 'test-consumer-izvczznrro'
kafka_server = '127.0.0.1:50245'
@_patch_objstorages(["src", "dst"])
def test_replay_content_exclude(
objstorages,
kafka_prefix: str,
kafka_consumer_group: str,
kafka_server: Tuple[Popen, int],
):
"""Check the content replayer in normal conditions
with a exclusion file (--exclude-sha1-file)
"""
contents = _fill_objstorage_and_kafka(
kafka_server, kafka_prefix, objstorages["src"]
)
excluded_contents = list(contents)[0::2] # picking half of them
with tempfile.NamedTemporaryFile(mode="w+b") as fd:
fd.write(b"".join(sorted(excluded_contents)))
fd.seek(0)
result = invoke(
"replay",
"--stop-after-objects",
str(NUM_CONTENTS),
"--exclude-sha1-file",
fd.name,
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:283: AssertionError
TEST RESULT
TEST RESULT
- Run At
- Dec 9 2021, 4:58 PM