diff --git a/swh/lister/save_bulk/lister.py b/swh/lister/save_bulk/lister.py index 65b3fbe4bf420bc14795a2ffadc312b0a5d0f1e0..f57766fea2d373bcd5635c93236724569dcb165c 100644 --- a/swh/lister/save_bulk/lister.py +++ b/swh/lister/save_bulk/lister.py @@ -289,6 +289,7 @@ class SaveBulkLister(Lister[SaveBulkListerState, SaveBulkListerPage]): max_origins_per_page=max_origins_per_page, max_pages=max_pages, enable_origins=enable_origins, + first_visits_queue_prefix="save_bulk", ) self.rejected_origins: Set[RejectedOrigin] = set() self.per_page = per_page diff --git a/swh/lister/save_bulk/tests/test_lister.py b/swh/lister/save_bulk/tests/test_lister.py index 30594d71510cd7094a191b017804ce8d97add576..b3365965aa9f326aa16e4485c7fb1881d6f31011 100644 --- a/swh/lister/save_bulk/tests/test_lister.py +++ b/swh/lister/save_bulk/tests/test_lister.py @@ -97,6 +97,9 @@ def test_bulk_lister_valid_origins(swh_scheduler, requests_mock, mocker): scheduler=swh_scheduler, per_page=PER_PAGE, ) + + assert lister_bulk.first_visits_queue_prefix == "save_bulk" + stats = lister_bulk.run() expected_nb_origins = len(SUBMITTED_ORIGINS)