def run(self):
        while 1:
            self.running = True
            workunit = self._workq.get()
            if is_sentinel(workunit):
                # Got sentinel
                break

            # Run the job / sequence
            workunit.process()
        self.running = False
audit active node configs
dataset/ETHPy150Open serverdensity/sd-agent/checks/libs/thread_pool.py/PoolWorker.run--crossover with--dataset/ETHPy150Open ohmu/poni/poni/tool.py/Tool.handle_audit