From b593b7ed591ffc3198221a84b1caa5dda03c586b Mon Sep 17 00:00:00 2001 From: Sergei Trofimov Date: Tue, 29 May 2018 09:50:41 +0100 Subject: [PATCH] fw/execution: wrap processors' process_job_output. Modify execution so that output processors' process_job_output() (but not export_job_output()) is wrapped by the JOB_OUTPUT_PROCESSED signals. This makes sense conceptually, and is more useful in practice, as there are already WORKLOAD_RESULT_EXTRACTION and WORKLOAD_OUTPUT_UPDATE signals sent by the job, if it's desirable to run before output processors, but after the job results have been collected. --- wa/framework/execution.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/wa/framework/execution.py b/wa/framework/execution.py index b908ec2b..03a1691b 100644 --- a/wa/framework/execution.py +++ b/wa/framework/execution.py @@ -581,7 +581,7 @@ class Runner(object): try: with signal.wrap('JOB_OUTPUT_PROCESSED', self, context): job.process_output(context) - self.pm.process_job_output(context) + self.pm.process_job_output(context) self.pm.export_job_output(context) except Exception as e: job.set_status(Status.PARTIAL)