'Attempts to gracefully shut down the worker threads'

def shutdown(self):

    log.info(('%s:    Sending    stop    signal    to    %s    worker    threads' % (self.runner_name, len(self.work_threads))))
    for i in range(len(self.work_threads)):
        self.work_queue.put((STOP_SIGNAL, None))
