Skip to content

Commit

Permalink
Discard changes to core/dbt/task/runnable.py
Browse files Browse the repository at this point in the history
  • Loading branch information
aranke authored Oct 14, 2024
1 parent 9caf000 commit f8d7b7c
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion core/dbt/task/runnable.py
Original file line number Diff line number Diff line change
Expand Up @@ -235,7 +235,6 @@ def call_runner(self, runner: BaseRunner) -> RunResult:
thread_exception = e
finally:
if result is not None:
runner.node.update_event_status(node_status=result.status)
fire_event(
NodeFinished(
node_info=runner.node.node_info,
Expand Down Expand Up @@ -265,6 +264,10 @@ def call_runner(self, runner: BaseRunner) -> RunResult:
node=runner.node,
)

# `_event_status` dict is only used for logging. Make sure
# it gets deleted when we're done with it
runner.node.clear_event_status()

fail_fast = get_flags().FAIL_FAST

if (
Expand Down

0 comments on commit f8d7b7c

Please sign in to comment.