D5045.id18001.diff
No OneTemporary
Actions

Size

1 KB

Subscribers

None

D5045.id18001.diff
View Options

	diff --git a/swh/storage/tests/test_replay.py b/swh/storage/tests/test_replay.py
	--- a/swh/storage/tests/test_replay.py
	+++ b/swh/storage/tests/test_replay.py
	@@ -312,6 +312,7 @@
	worker_fn = functools.partial(process_replay_objects, storage=dst_storage)

	nb_inserted = replayer.process(worker_fn)
	+ replayer.consumer.commit()
	assert nb_sent == nb_inserted
	check_replayed(storage, dst_storage, expected_anonymized=True)

	@@ -319,7 +320,7 @@
	dst_storage = get_storage(cls="memory")
	replayer = JournalClient(
	brokers=kafka_server,
	- group_id=kafka_consumer_group,
	+ group_id=f"{kafka_consumer_group}-2",
	prefix=kafka_prefix,
	stop_after_objects=nb_sent,
	privileged=True,
	@@ -327,6 +328,7 @@
	worker_fn = functools.partial(process_replay_objects, storage=dst_storage)

	nb_inserted = replayer.process(worker_fn)
	+ replayer.consumer.commit()
	assert nb_sent == nb_inserted
	check_replayed(storage, dst_storage, expected_anonymized=False)