def explicitly_close_queues(self):
        self.safe_close_queue('input', self.input_queue)
        self.safe_close_queue('output', self.output_queue)
Explicitly join queues, so that we'll get "stuck" in something that's
dataset/ETHPy150Open gatoatigrado/vimap/vimap/real_worker_routine.py/WorkerRoutine.explicitly_close_queues