eksupdate/src/k8s_client.py [14:23]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
queue = queue.Queue()
class StatsWorker(threading.Thread):

    def __init__(self, queue,id):
        threading.Thread.__init__(self)
        self.queue = queue
        self.id=id

    def run(self):
        while self.queue.not_empty:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



eksupdate/starter.py [15:24]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
queue = queue.Queue()
class StatsWorker(threading.Thread):

    def __init__(self, queue,id):
        threading.Thread.__init__(self)
        self.queue = queue
        self.id=id

    def run(self):
        while self.queue.not_empty:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -