opendev/puppet-subunit2sql
Code Issues Proposed changes

Merge "Add source_url to mqtt payload"

Browse Source
This commit is contained in:
Jenkins 2017-04-28 21:05:06 +00:00 committed by Gerrit Code Review
commit c2beb42105
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
files/subunit-gearman-worker.py
View File

@ -111,6 +111,7 @@ class SubunitRetriever(object):
def _handle_event(self): def _handle_event(self):
fields = {} fields = {}
source_url = ''
job = self.gearman_worker.getJob() job = self.gearman_worker.getJob()
try: try:
arguments = json.loads(job.arguments.decode('utf-8')) arguments = json.loads(job.arguments.decode('utf-8'))
@ -138,6 +139,7 @@ class SubunitRetriever(object):
if self.mqtt: if self.mqtt:
msg = json.dumps({ msg = json.dumps({
'build_uuid': out_event.get('build_uuid'), 'build_uuid': out_event.get('build_uuid'),
'source_url': source_url,
'status': 'success', 'status': 'success',
}) })
self.mqtt.publish_single(msg, out_event.get('project'), self.mqtt.publish_single(msg, out_event.get('project'),
@ -148,6 +150,7 @@ class SubunitRetriever(object):
if self.mqtt: if self.mqtt:
msg = json.dumps({ msg = json.dumps({
'build_uuid': fields.get('build_uuid'), 'build_uuid': fields.get('build_uuid'),
'source_url': source_url,
'status': 'failed', 'status': 'failed',
}) })
self.mqtt.publish_single(msg, fields.get('project'), self.mqtt.publish_single(msg, fields.get('project'),