Stop using a seperate retreiver thread
Since we recently switched from having 2 threads, 1 to retreive subunit and 1 to process it, to having a single thread do both there isn't any reason to launch to run that in a separate thread anymore. This commit just removes the use of threading and runs everything in the single process. Change-Id: I5205fc73178b7d5a4bbee61e68b16b63499f5dd8
This commit is contained in:
parent
fa17a37a52
commit
fa6b116168
|
@ -23,7 +23,6 @@ import json
|
|||
import logging
|
||||
import os
|
||||
import socket
|
||||
import threading
|
||||
import time
|
||||
import urllib2
|
||||
import yaml
|
||||
|
@ -54,9 +53,9 @@ class FilterException(Exception):
|
|||
pass
|
||||
|
||||
|
||||
class SubunitRetriever(threading.Thread):
|
||||
class SubunitRetriever(object):
|
||||
def __init__(self, gearman_worker, filters, subunit2sql_conf):
|
||||
threading.Thread.__init__(self)
|
||||
super(SubunitRetriever, self).__init__()
|
||||
self.gearman_worker = gearman_worker
|
||||
self.filters = filters
|
||||
# Initialize subunit2sql settings
|
||||
|
@ -233,7 +232,7 @@ class Server(object):
|
|||
|
||||
def main(self):
|
||||
self.setup_retriever()
|
||||
self.retriever.start()
|
||||
self.retriever.run()
|
||||
|
||||
|
||||
def main():
|
||||
|
|
Loading…
Reference in New Issue