Page MenuHomeSoftware Heritage

D5045.id18001.diff
No OneTemporary

D5045.id18001.diff

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)

File Metadata

Mime Type
text/plain
Expires
Thu, Jul 3, 3:26 PM (1 w, 1 d ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3217629

Event Timeline