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

fw/exec: add JOB_QUEUE_EXECUTION signals

Browse Source 
Add signals just before and just after commencing the execution of the
job queue.
This commit is contained in:
Sergei Trofimov 2018-06-12 14:16:22 +01:00 committed by setrofim
parent 5f7fde206d
commit ea97372ece
3 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
wa/framework/execution.py
View File

@ -454,10 +454,11 @@ class Runner(object):
self.initialize_run()
self.send(signal.RUN_INITIALIZED)
while self.context.job_queue:
if self.context.run_interrupted:
raise KeyboardInterrupt()
self.run_next_job(self.context)
with signal.wrap('JOB_QUEUE_EXECUTION', self, self.context):
while self.context.job_queue:
if self.context.run_interrupted:
raise KeyboardInterrupt()
self.run_next_job(self.context)
except KeyboardInterrupt as e:
log.log_error(e, self.logger)

4
wa/framework/instrument.py
View File

@ -140,6 +140,10 @@ SIGNAL_MAP = OrderedDict([
('on_job_failure', signal.JOB_FAILED),
('on_job_abort', signal.JOB_ABORTED),
('before_job_queue_execution', signal.BEFORE_JOB_QUEUE_EXECUTION),
('on_successful_job_queue_exection', signal.SUCCESSFUL_JOB_QUEUE_EXECUTION),
('after_job_queue_execution', signal.AFTER_JOB_QUEUE_EXECUTION),
('before_job', signal.BEFORE_JOB),
('on_successful_job', signal.SUCCESSFUL_JOB),
('after_job', signal.AFTER_JOB),

5
wa/framework/signal.py
View File

@ -128,7 +128,6 @@ BEFORE_WORKLOAD_FINALIZED = Signal('before-workload-finalized', invert_priority=
SUCCESSFUL_WORKLOAD_FINALIZED = Signal('successful-workload-finalized')
AFTER_WORKLOAD_FINALIZED = Signal('after-workload-finalized')
# Signals indicating exceptional conditions
ERROR_LOGGED = Signal('error-logged')
WARNING_LOGGED = Signal('warning-logged')
@ -146,6 +145,10 @@ BEFORE_JOB = Signal('before-job', invert_priority=True)
SUCCESSFUL_JOB = Signal('successful-job')
AFTER_JOB = Signal('after-job')
BEFORE_JOB_QUEUE_EXECUTION = Signal('before-job-queue-execution', invert_priority=True)
SUCCESSFUL_JOB_QUEUE_EXECUTION = Signal('successful-job-queue-execution')
AFTER_JOB_QUEUE_EXECUTION = Signal('after-job-queue-execution')
BEFORE_JOB_TARGET_CONFIG = Signal('before-job-target-config', invert_priority=True)
SUCCESSFUL_JOB_TARGET_CONFIG = Signal('successful-job-target-config')
AFTER_JOB_TARGET_CONFIG = Signal('after-job-target-config')