diff --git a/core/dbt/task/run.py b/core/dbt/task/run.py index ce613c0e44d..0b6fae4fc4c 100644 --- a/core/dbt/task/run.py +++ b/core/dbt/task/run.py @@ -568,6 +568,9 @@ def _execute_microbatch_materialization( # At least one batch has been inserted successfully! incremental_batch = True + except (KeyboardInterrupt, SystemExit): + # reraise it for GraphRunnableTask.execute_nodes to handle + raise except Exception as e: exception = e batch_run_result = self._build_failed_run_batch_result(