diff --git a/dvc/stage.py b/dvc/stage.py index 72367031f..ddf1e1342 100644 --- a/dvc/stage.py +++ b/dvc/stage.py @@ -775,9 +775,6 @@ class Stage(object): main_thread = isinstance( threading.current_thread(), threading._MainThread ) - if main_thread: - old_handler = signal.signal(signal.SIGINT, signal.SIG_IGN) - p = None try: @@ -789,6 +786,8 @@ class Stage(object): executable=executable, close_fds=True, ) + if main_thread: + old_handler = signal.signal(signal.SIGINT, signal.SIG_IGN) p.communicate() finally: if main_thread: