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