summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--files/subunit-gearman-worker.py11
1 files changed, 6 insertions, 5 deletions
diff --git a/files/subunit-gearman-worker.py b/files/subunit-gearman-worker.py
index bcaab0f..11b447d 100644
--- a/files/subunit-gearman-worker.py
+++ b/files/subunit-gearman-worker.py
@@ -85,11 +85,12 @@ class SubunitRetriever(threading.Thread):
85 if not subunit_io: 85 if not subunit_io:
86 job.sendWorkException( 86 job.sendWorkException(
87 'Unable to retrieve subunit stream'.encode('utf8')) 87 'Unable to retrieve subunit stream'.encode('utf8'))
88 logging.debug("Pushing subunit files.") 88 else:
89 out_event = fields.copy() 89 logging.debug("Pushing subunit files.")
90 out_event["subunit"] = subunit_io 90 out_event = fields.copy()
91 self.subunitq.put(out_event) 91 out_event["subunit"] = subunit_io
92 job.sendWorkComplete() 92 self.subunitq.put(out_event)
93 job.sendWorkComplete()
93 except Exception as e: 94 except Exception as e:
94 logging.exception("Exception handling log event.") 95 logging.exception("Exception handling log event.")
95 job.sendWorkException(str(e).encode('utf-8')) 96 job.sendWorkException(str(e).encode('utf-8'))