diff --git a/core/dbt/task/run.py b/core/dbt/task/run.py index 99913a551c5..8611b3ce56a 100644 --- a/core/dbt/task/run.py +++ b/core/dbt/task/run.py @@ -549,6 +549,9 @@ def _execute_microbatch_materialization( # Update context vars for future batches context["is_incremental"] = lambda: True context["should_full_refresh"] = lambda: False + 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(