def __exit__(self, type, value, traceback):
        self._keep_alive_thread.stop()
        self._keep_alive_thread.join()
        for task in self._running_tasks.values():
            if task.is_alive():
                task.terminate()
        return False  # Don't suppress exception
Stop the KeepAliveThread and kill still running tasks.
dataset/ETHPy150Open spotify/luigi/luigi/worker.py/Worker.__exit__