From 7c186f5d0e6d66e14667d6ab68b286fe32ab6ec2 Mon Sep 17 00:00:00 2001 From: Adam Rutkowski Date: Sun, 3 Apr 2022 16:06:34 +0200 Subject: [PATCH] pyocf: make queues a required rio param Signed-off-by: Adam Rutkowski --- tests/functional/pyocf/rio.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/tests/functional/pyocf/rio.py b/tests/functional/pyocf/rio.py index 1462c16..441ba10 100644 --- a/tests/functional/pyocf/rio.py +++ b/tests/functional/pyocf/rio.py @@ -261,12 +261,12 @@ class Rio: self._threads = [] self.errors = {} - def run(self, queues=None): + def run(self, queues): self.run_async(queues) self.wait_for_completion() return self - def run_async(self, queues=None): + def run_async(self, queues): self.clear() jobs = deepcopy(self.jobs) @@ -274,8 +274,6 @@ class Rio: if not jobs: jobs = [self.global_jobspec for _ in range(self.global_jobspec.njobs)] - if not queues: - queues = [self.global_jobspec.target.cache.get_default_queue()] queues = cycle(queues) for job in jobs: