diff --git a/worker/manager/src/mirrors_qa_manager/worker.py b/worker/manager/src/mirrors_qa_manager/worker.py index e472803..52456c4 100644 --- a/worker/manager/src/mirrors_qa_manager/worker.py +++ b/worker/manager/src/mirrors_qa_manager/worker.py @@ -311,11 +311,11 @@ def fetch_tests(self) -> Iterable[dict[str, str]]: f"Fetched page {current_page} of {last_page} of pending tests." ) + yield from data["tests"] + if current_page == last_page: raise StopIteration - yield from data["tests"] - def sleep(self) -> None: logger.info(f"Sleeping for {Settings.SLEEP_SECONDS}s") time.sleep(Settings.SLEEP_SECONDS)