diff --git a/sisyphus/manager.py b/sisyphus/manager.py index 44a1e0f..1ff592d 100644 --- a/sisyphus/manager.py +++ b/sisyphus/manager.py @@ -548,11 +548,11 @@ def maybe_clear_state(state, always_clear, action): self.print_state_overview(verbose=True) elif answer.lower() == "y": self.link_outputs = True - threading.Thread(target=create_aliases, args=(self.sis_graph.jobs(),)).start() - threading.Thread( - target=self.check_output, - kwargs={"write_output": self.link_outputs, "update_all_outputs": True, "force_update": True}, - ).start() + self.thread_pool.apply_async(create_aliases, self.sis_graph.jobs()) + self.thread_pool.apply_async( + self.check_output, + kwds={"write_output": self.link_outputs, "update_all_outputs": True, "force_update": True}, + ) break elif answer.lower() == "u": self.link_outputs = True