github/ocf
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

pyocf: make queues a required rio param

Browse Source 
Signed-off-by: Adam Rutkowski <adam.j.rutkowski@intel.com>
This commit is contained in:
Adam Rutkowski 2022-04-03 16:06:34 +02:00
parent c37ffea4c2
commit 7c186f5d0e
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/functional/pyocf/rio.py
View File

@ -261,12 +261,12 @@ class Rio:
self._threads = [] self._threads = []
self.errors = {} self.errors = {}
def run(self, queues=None): def run(self, queues):
self.run_async(queues) self.run_async(queues)
self.wait_for_completion() self.wait_for_completion()
return self return self
def run_async(self, queues=None): def run_async(self, queues):
self.clear() self.clear()
jobs = deepcopy(self.jobs) jobs = deepcopy(self.jobs)
@ -274,8 +274,6 @@ class Rio:
if not jobs: if not jobs:
jobs = [self.global_jobspec for _ in range(self.global_jobspec.njobs)] 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) queues = cycle(queues)
for job in jobs: for job in jobs: