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

fw/signal: add job signals

Browse Source 
Add matched signals for before-after job execution. These are the
equivalent of "spec" signals in WA2.
This commit is contained in:
Sergei Trofimov
2018-05-29 09:20:52 +01:00
committed by Marc Bonnici
parent 0dc9390978
commit 573c6abcb5
3 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
wa/framework/execution.py
View File

@@ -509,9 +509,10 @@ class Runner(object):
self.logger.info('Rebooting on new spec.') self.logger.info('Rebooting on new spec.')
self.context.tm.target.reboot() self.context.tm.target.reboot()
context.tm.start() with signal.wrap('JOB', self, context):
self.do_run_job(job, context) context.tm.start()
job.set_status(Status.OK) self.do_run_job(job, context)
job.set_status(Status.OK)
except (Exception, KeyboardInterrupt) as e: # pylint: disable=broad-except except (Exception, KeyboardInterrupt) as e: # pylint: disable=broad-except
log.log_error(e, self.logger) log.log_error(e, self.logger)
if isinstance(e, KeyboardInterrupt): if isinstance(e, KeyboardInterrupt):

4
wa/framework/instrument.py
View File

@@ -131,6 +131,10 @@ SIGNAL_MAP = OrderedDict([
('teardown', signal.AFTER_WORKLOAD_TEARDOWN), ('teardown', signal.AFTER_WORKLOAD_TEARDOWN),
('finalize', signal.RUN_FINALIZED), ('finalize', signal.RUN_FINALIZED),
('before_job', signal.BEFORE_JOB),
('on_successful_job', signal.SUCCESSFUL_JOB),
('after_job', signal.AFTER_JOB),
# ('on_run_start', signal.RUN_START), # ('on_run_start', signal.RUN_START),
# ('on_run_end', signal.RUN_END), # ('on_run_end', signal.RUN_END),
# ('on_workload_spec_start', signal.WORKLOAD_SPEC_START), # ('on_workload_spec_start', signal.WORKLOAD_SPEC_START),

4
wa/framework/signal.py
View File

@@ -143,6 +143,10 @@ BEFORE_RUN_INIT = Signal('before-run-init', invert_priority=True)
SUCCESSFUL_RUN_INIT = Signal('successful-run-init') SUCCESSFUL_RUN_INIT = Signal('successful-run-init')
AFTER_RUN_INIT = Signal('after-run-init') AFTER_RUN_INIT = Signal('after-run-init')
BEFORE_JOB = Signal('before-job', invert_priority=True)
SUCCESSFUL_JOB = Signal('successful-job')
AFTER_JOB = Signal('after-job')
BEFORE_JOB_TARGET_CONFIG = Signal('before-job-target-config', invert_priority=True) BEFORE_JOB_TARGET_CONFIG = Signal('before-job-target-config', invert_priority=True)
SUCCESSFUL_JOB_TARGET_CONFIG = Signal('successful-job-target-config') SUCCESSFUL_JOB_TARGET_CONFIG = Signal('successful-job-target-config')
AFTER_JOB_TARGET_CONFIG = Signal('after-job-target-config') AFTER_JOB_TARGET_CONFIG = Signal('after-job-target-config')