sascha/workload-automation
1
0
Fork 0
mirror of https://github.com/ARM-software/workload-automation.git synced 2025-02-07 13:41:24 +00:00
Code Issues Releases Wiki Activity

Merge pull request #406 from AnthonyARM/master

Browse Source 
Replaced active_cpus by online_cpus in common/linux/device.py
This commit is contained in:
setrofim 2017-06-15 09:58:47 +01:00 committed by GitHub
commit 2172db5833
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
wlauto/common/linux/device.py
View File

@ -518,10 +518,10 @@ class BaseLinuxDevice(Device): # pylint: disable=abstract-method
def get_number_of_online_cores(self, core): def get_number_of_online_cores(self, core):
if core not in self.core_names: if core not in self.core_names:
raise ValueError('Unexpected core: {}; must be in {}'.format(core, list(set(self.core_names)))) raise ValueError('Unexpected core: {}; must be in {}'.format(core, list(set(self.core_names))))
active_cpus = self.active_cpus online_cpus = self.online_cpus
num_active_cores = 0 num_active_cores = 0
for i, c in enumerate(self.core_names): for i, c in enumerate(self.core_names):
if c == core and i in active_cpus: if c == core and i in online_cpus:
num_active_cores += 1 num_active_cores += 1
return num_active_cores return num_active_cores

2
wlauto/core/execution.py
View File

@ -642,7 +642,7 @@ class Runner(object):
job.iteration = self.context.current_iteration job.iteration = self.context.current_iteration
if job.result.status in self.config.retry_on_status: if job.result.status in self.config.retry_on_status:
if job.retry >= self.config.max_retries: if job.retry >= self.config.max_retries:
self.logger.error('Exceeded maxium number of retries. Abandoning job.') self.logger.error('Exceeded maximum number of retries. Abandoning job.')
else: else:
self.logger.info('Job status was {}. Retrying...'.format(job.result.status)) self.logger.info('Job status was {}. Retrying...'.format(job.result.status))
retry_job = RunnerJob(job.spec, job.retry + 1) retry_job = RunnerJob(job.spec, job.retry + 1)