From 390f44eb0ee4aaaf399928294e6ed2f6498c3db4 Mon Sep 17 00:00:00 2001 From: Clint Byrum Date: Wed, 11 Nov 2015 18:03:46 -0800 Subject: [PATCH] Allow worker to make use of subunit2sql targets A plugin interface has been added, so make sure we load them. This will allow us to eventually ingest counters while processing the stream. Change-Id: I0614986eeae3c6f4681162c755311eab5a730862 Depends-On: Id16c87382f3767982ce815d129ae56a941375546 Implements: counter-inspection --- files/subunit-gearman-worker.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/files/subunit-gearman-worker.py b/files/subunit-gearman-worker.py index ce2c8f2..4ec80e6 100644 --- a/files/subunit-gearman-worker.py +++ b/files/subunit-gearman-worker.py @@ -170,7 +170,9 @@ class Subunit2SQLProcessor(object): self.config = subunit2sql_conf # Initialize subunit2sql settings shell.cli_opts() + extensions = shell.get_extensions() shell.parse_args([], [self.config]) + self.extra_targets = shell.get_targets(extensions) def handle_subunit_event(self): # Pull subunit event from queue and separate stream from metadata @@ -184,7 +186,8 @@ class Subunit2SQLProcessor(object): shell.CONF.set_override('run_meta', subunit) # Parse subunit stream and store in DB logging.debug('Converting Subunit V2 stream to SQL') - stream = read_subunit.ReadSubunit(subunit_v2) + stream = read_subunit.ReadSubunit(subunit_v2, + targets=self.extra_targets) shell.process_results(stream.get_results())