diff options
author | Waleed El-Geresy <waleed.el-geresy@arm.com> | 2018-09-04 17:18:25 +0100 |
---|---|---|
committer | Marc Bonnici <marc.bonnici@arm.com> | 2018-09-05 14:40:42 +0100 |
commit | 718f2c1c902e656f7fe1f4762be9fed11efc3fe6 (patch) | |
tree | fa1437786d3c4d3dba9bfb32d556fedad5727fc4 /wa/framework | |
parent | 4c4fd2a2671e485c10e5b82fc7feb75aa511555d (diff) |
Expose context in OP initialize and finalize
Expose the context to the initialize and finalize functions for Output
Processors. This was found to be necessary for the upcoming PostgreSQL
Output Processor.
Diffstat (limited to 'wa/framework')
-rw-r--r-- | wa/framework/execution.py | 4 | ||||
-rw-r--r-- | wa/framework/output_processor.py | 12 |
2 files changed, 8 insertions, 8 deletions
diff --git a/wa/framework/execution.py b/wa/framework/execution.py index 1e06ab19..ebcb6860 100644 --- a/wa/framework/execution.py +++ b/wa/framework/execution.py @@ -516,7 +516,7 @@ class Runner(object): signal.connect(self._error_signalled_callback, signal.ERROR_LOGGED) signal.connect(self._warning_signalled_callback, signal.WARNING_LOGGED) self.context.start_run() - self.pm.initialize() + self.pm.initialize(self.context) with log.indentcontext(): self.context.initialize_jobs() self.context.write_state() @@ -532,7 +532,7 @@ class Runner(object): with signal.wrap('RUN_OUTPUT_PROCESSED', self): self.pm.process_run_output(self.context) self.pm.export_run_output(self.context) - self.pm.finalize() + self.pm.finalize(self.context) signal.disconnect(self._error_signalled_callback, signal.ERROR_LOGGED) signal.disconnect(self._warning_signalled_callback, signal.WARNING_LOGGED) diff --git a/wa/framework/output_processor.py b/wa/framework/output_processor.py index 76654083..6fe80f7e 100644 --- a/wa/framework/output_processor.py +++ b/wa/framework/output_processor.py @@ -40,10 +40,10 @@ class OutputProcessor(Plugin): msg = 'Instrument "{}" is required by {}, but is not installed.' raise ConfigError(msg.format(instrument, self.name)) - def initialize(self): + def initialize(self, context): pass - def finalize(self): + def finalize(self, context): pass @@ -104,13 +104,13 @@ class ProcessorManager(object): for proc in self.processors: proc.validate() - def initialize(self): + def initialize(self, context): for proc in self.processors: - proc.initialize() + proc.initialize(context) - def finalize(self): + def finalize(self, context): for proc in self.processors: - proc.finalize() + proc.finalize(context) def process_job_output(self, context): self.do_for_each_proc('process_job_output', 'Processing using "{}"', |