D2749.diff
No OneTemporary
Actions

Size

1 KB

Subscribers

None

D2749.diff
View Options

	diff --git a/requirements-swh.txt b/requirements-swh.txt
	--- a/requirements-swh.txt
	+++ b/requirements-swh.txt
	@@ -1,3 +1,3 @@
	swh.core[db,http] >= 0.0.60
	swh.model >= 0.0.40
	-swh.storage >= 0.0.156
	+swh.storage >= 0.0.172
	diff --git a/swh/journal/tests/test_write_replay.py b/swh/journal/tests/test_write_replay.py
	--- a/swh/journal/tests/test_write_replay.py
	+++ b/swh/journal/tests/test_write_replay.py
	@@ -139,9 +139,13 @@
	replayer.max_messages = queue_size

	storage2 = get_storage(**storage_config)
	+
	+ objstorage1 = storage1.objstorage.objstorage
	+ objstorage2 = storage2.objstorage.objstorage
	+
	worker_fn = functools.partial(process_replay_objects_content,
	- src=storage1.objstorage,
	- dst=storage2.objstorage)
	+ src=objstorage1,
	+ dst=objstorage2)
	nb_messages = 0
	while nb_messages < queue_size:
	nb_messages += replayer.process(worker_fn)
	@@ -151,4 +155,4 @@
	c['sha1']: c['data'] for c in contents if c['status'] == 'visible'
	}

	- assert expected_objstorage_state == storage2.objstorage.state
	+ assert expected_objstorage_state == objstorage2.state