package v1.public.events.fusion.node

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: NodeEvaluated, NodeProcessed

• NodeCacheReason node_cache_reason = 1

• optional uint64 build_after_seconds = 2

  If node_cache_reason == NODE_CACHE_REASON_STILL_FRESH, this field indicates freshness period for this node in seconds.

• optional uint64 last_updated_seconds = 3

  If node_cache_reason == NODE_CACHE_REASON_STILL_FRESH, this field indicates time since last update in seconds.

Cache reuse classification when node_skip_reason == NODE_SKIP_REASON_CACHED.

Used in: NodeCacheDetail

• NODE_CACHE_REASON_NO_CHANGES = 0

  Reused from cache - no code or data changes detected.

• NODE_CACHE_REASON_STILL_FRESH = 1

  Reused from cache - changes detected but still within freshness window.

• NODE_CACHE_REASON_UPDATE_CRITERIA_NOT_MET = 2

  Reused from cache - changes detected but update criteria not met.

• NODE_CACHE_REASON_CLONED_EXISTING = 3

  Reused by cloning an existing relation.

• NODE_CACHE_REASON_CLONED_EXISTING_STILL_FRESH = 4

  Reused by cloning an existing relation within freshness tolerance.

Reasons why a node evaluation was cabceled.

Used in: NodeEvaluated, NodeProcessed

• NODE_CANCEL_REASON_USER_CANCELLED = 0

  User explicitly cancelled execution (e.g. ctrl-c).

Categorization of aggregated errors for debugging and retry logic. Errors form a hierarchy: if any internal error occurred, the aggregated result is INTERNAL. Otherwise if any external error occurred it is EXTERNAL. Otherwise it is USER.

Used in: NodeEvaluated, NodeProcessed

• NODE_ERROR_TYPE_INTERNAL = 0

  Internal dbt error (bug, panic, unexpected state) – not recoverable by retrying.

• NODE_ERROR_TYPE_EXTERNAL = 1

  External system error (database down, network issue, etc.) – potentially recoverable by retrying.

• NODE_ERROR_TYPE_USER = 2

  User code error (SQL syntax, compilation error, etc.) that must be fixed by the user.

• string unique_id = 1

  unique_id is the globally unique identifier for this node.

• string name = 2

  Node name.

• optional string database = 3

  Database where this node will be created if applicable.

• optional string schema = 4

  Schema where this node will be created if applicable.

• optional string identifier = 5

  Name of the relation (table, view, etc.) that will be created for this node if applicable.

• optional NodeMaterialization materialization = 7

  How this node is materialized in the data warehouse.

• optional string custom_materialization = 8

  If materialization == NODE_MATERIALIZATION_CUSTOM, this field contains the custom materialization name.

• NodeType node_type = 9

  Type of node being evaluated. Known as `resource_type` in dbt core.

• NodeOutcome node_outcome = 10

  Core outcome for this evaluation.

• phase.ExecutionPhase phase = 11

  Execution phase during which this node was evaluated.

• string relative_path = 12

  Relative path to the file containing node definition within the dbt project.

• optional uint32 defined_at_line = 13

  Line number (1-indexed) where the test is defined (only applicable to test nodes)

• optional uint32 defined_at_col = 14

  Column number (0-indexed) of where the test is defined (only applicable to test nodes)

• string node_checksum = 15

  Checksum of the node definition

• optional bool sao_enabled = 16

  Whether or not SAO was enabled for this node during evaluation. Only set for run phase.

• optional NodeErrorType node_error_type = 20

  Categorization of aggregated errors for debugging and retry logic. Present when node_outcome == NODE_OUTCOME_ERROR.

• optional NodeCancelReason node_cancel_reason = 21

  Cancellation reason. Present when node_outcome == NODE_OUTCOME_CANCELED.

• optional NodeSkipReason node_skip_reason = 22

  Detailed reason for skipping this node. Present when node_outcome == NODE_OUTCOME_SKIPPED.

• oneof node_outcome_detail

  Node type specific details (e.g. test fail counts, cache use reasons).

  • NodeCacheDetail node_cache_detail = 30

    Detailed reason why cache was used. Present when node_skip_reason == NODE_SKIP_REASON_CACHED.

  • TestEvaluationDetail node_test_detail = 31

    Test specific outcome details. Present for test / unit test node types when node_outcome == NODE_OUTCOME_SUCCESS.

  • SourceFreshnessDetail node_freshness_outcome = 32

    Source freshness specific outcome details. Present for source nodes with freshness checks when node_outcome == NODE_OUTCOME_SUCCESS.

  • NodeSkipUpstreamDetail node_skip_upstream_detail = 33

    Upstream node that caused this node to be skipped. Present when node_skip_reason == NODE_SKIP_REASON_UPSTREAM.

  • NodeEvaluationDetail node_evaluation_detail = 34

    Non-test node specific outcome details. Present for non test / unit test / source node types when node_outcome == NODE_OUTCOME_SUCCESS.

• optional string dbt_core_event_code = 40

  Optional legacy dbt core event code (e.g. "Q018") if this event has a strict mapping to a dbt core event.

• optional uint64 rows_affected = 41

  Number of rows affected by this node evaluation, if available. Only set for successful outcomes where row count is known (e.g., models, seeds).

• optional uint64 idle_time_ms = 42

  Total time in milliseconds this node evaluation spent idle. This includes time spent waiting on internal backpressure.

Non-test node specific outcome details for a successful evaluation. node_warning_outcome is always set (non-UNSPECIFIED) for new records; UNSPECIFIED only appears in records written before this field existed (backward compat).

Used in: NodeEvaluated, NodeProcessed

• NodeWarningOutcome node_warning_outcome = 1

Used in: NodeEvaluated, NodeProcessed

• NODE_MATERIALIZATION_UNKNOWN = 0

• NODE_MATERIALIZATION_SNAPSHOT = 1

• NODE_MATERIALIZATION_SEED = 2

• NODE_MATERIALIZATION_VIEW = 3

• NODE_MATERIALIZATION_TABLE = 4

• NODE_MATERIALIZATION_INCREMENTAL = 5

• NODE_MATERIALIZATION_MATERIALIZED_VIEW = 6

• NODE_MATERIALIZATION_EXTERNAL = 7

• NODE_MATERIALIZATION_TEST = 8

• NODE_MATERIALIZATION_EPHEMERAL = 9

• NODE_MATERIALIZATION_UNIT = 10

• NODE_MATERIALIZATION_ANALYSIS = 11

• NODE_MATERIALIZATION_STREAMING_TABLE = 12

  ONLY FOR DATABRICKS

• NODE_MATERIALIZATION_DYNAMIC_TABLE = 13

  ONLY FOR SNOWFLAKE

• NODE_MATERIALIZATION_FUNCTION = 14

• NODE_MATERIALIZATION_CUSTOM = 100

Core outcome for any node evaluation result within any phase. Represents the aggregated result of all operations in the phase

Used in: NodeEvaluated, NodeProcessed

• NODE_OUTCOME_UNSPECIFIED = 0

  Default value. Should only be set on unfinished spans

• NODE_OUTCOME_SUCCESS = 1

  Successfully completed all operations in the phase. Some node types also store a type specific outcome for successful completion.

• NODE_OUTCOME_ERROR = 2

  Failed with an aggregated error type (individual errors reported as separate events). If set, `node_error_type` with also be set to indicate the type of error.

• NODE_OUTCOME_CANCELED = 3

  Operation was canceled (e.g. user-initiated cancellation). If set, `node_cancel_reason` will also be set to indicate the reason for the cancelation.

• NODE_OUTCOME_SKIPPED = 4

  Skipped evaluation for a specific reason. If set, `node_skip_reason` will also be set to indicate the reason for the skip.

Span event tracking full processing of a node across all phases. Supersedes legacy NodeStart (Q024) and NodeFinished (Q025) events.

• string unique_id = 1

  unique_id is the globally unique identifier for this node.

• string name = 2

  Node name.

• optional string database = 3

  Database where this node will be created if applicable.

• optional string schema = 4

  Schema where this node will be created if applicable.

• optional string identifier = 5

  Name of the relation (table, view, etc.) that will be created for this node if applicable.

• optional string source_name = 6

  Name of the source for source nodes.

• optional NodeMaterialization materialization = 7

  How this node is materialized in the data warehouse.

• optional string custom_materialization = 8

  If materialization == NODE_MATERIALIZATION_CUSTOM, this field contains the custom materialization name.

• NodeType node_type = 9

  Type of node being evaluated. Known as `resource_type` in dbt core.

• NodeOutcome node_outcome = 10

  Core outcome for this node processing across all phases.

• phase.ExecutionPhase last_phase = 11

  Last execution phase that was reached during processing (or would have been reached if not skipped).

• string relative_path = 12

  Relative path to the file containing node definition within the dbt project.

• optional uint32 defined_at_line = 13

  Line number (1-indexed) where the test is defined (only applicable to test nodes)

• optional uint32 defined_at_col = 14

  Column number (0-indexed) of where the test is defined (only applicable to test nodes)

• string node_checksum = 15

  Checksum of the node definition

• optional bool sao_enabled = 16

  Whether or not SAO was enabled for this node during evaluation. Only set for invocations, that include the run phase.

• optional NodeErrorType node_error_type = 20

  Categorization of aggregated errors for debugging and retry logic. Present when node_outcome == NODE_OUTCOME_ERROR.

• optional NodeCancelReason node_cancel_reason = 21

  Cancellation reason. Present when node_outcome == NODE_OUTCOME_CANCELED.

• optional NodeSkipReason node_skip_reason = 22

  Detailed reason for skipping this node. Present when node_outcome == NODE_OUTCOME_SKIPPED.

• oneof node_outcome_detail

  Node type specific details (e.g. test fail counts, cache use reasons).

  • NodeCacheDetail node_cache_detail = 30

    Detailed reason why cache was used. Present when node_skip_reason == NODE_SKIP_REASON_CACHED.

  • TestEvaluationDetail node_test_detail = 31

    Test specific outcome details. Present for test / unit test node types when node_outcome == NODE_OUTCOME_SUCCESS.

  • SourceFreshnessDetail node_freshness_outcome = 32

    Source freshness specific outcome details. Present for source nodes with freshness checks when node_outcome == NODE_OUTCOME_SUCCESS.

  • NodeSkipUpstreamDetail node_skip_upstream_detail = 33

    Upstream node that caused this node to be skipped. Present when node_skip_reason == NODE_SKIP_REASON_UPSTREAM.

  • NodeEvaluationDetail node_evaluation_detail = 34

    Non-test node specific outcome details. Present for non test / unit test / source node types when node_outcome == NODE_OUTCOME_SUCCESS.

• string dbt_core_event_code = 40

  Legacy dbt core event code. Always set to Q024 for start, Q025 for end.

• optional uint64 duration_ms = 41

  Total duration in milliseconds of all nested NodeEvaluated spans. This reflects the actual time spent processing the node, excluding time waiting for upstream nodes.

• bool in_selection = 42

  Some node's maybe be anaklyzed but not selected for execution. This flag indicates whether the node was in the selection set.

• optional uint64 rows_affected = 43

  Number of rows affected by this node processing, if available. Only set for successful outcomes where row count is known (e.g., models, seeds).

• optional string group = 44

  Group identifier for model level notifications

• optional uint64 idle_time_ms = 45

  Total time in milliseconds spent idle across all nested node evaluations. This includes time spent waiting on internal backpressure.

Reasons why a node may be skipped. Only applies to nodes selected for evaluation.

Used in: NodeEvaluated, NodeProcessed

• NODE_SKIP_REASON_UNSPECIFIED = 0

• NODE_SKIP_REASON_UPSTREAM = 1

  Skipped because an upstream dependency prevents this node from running (for any reason).

• NODE_SKIP_REASON_CACHED = 2

  Reused from cache

• NODE_SKIP_REASON_PHASE_DISABLED = 3

  Current evaluation phase disabled for this node by configuration / flags.

• NODE_SKIP_REASON_NO_OP = 4

  Operation had no effect (e.g. ephemeral models).

• NODE_SKIP_REASON_PHASE_SKIPPED = 5

  Current evaluation phase skipped for this node due to previous phase outcome.

Used in: NodeEvaluated, NodeProcessed

• string upstream_unique_id = 1

  unique_id of the upstream node that caused this node to be skipped.

Node type, also known as "resource type" in dbt core.

Used in: NodeEvaluated, NodeProcessed

• NODE_TYPE_UNSPECIFIED = 0

• NODE_TYPE_MODEL = 1

• NODE_TYPE_SEED = 2

• NODE_TYPE_SNAPSHOT = 11

• NODE_TYPE_SOURCE = 3

• NODE_TYPE_TEST = 4

• NODE_TYPE_UNIT_TEST = 5

• NODE_TYPE_MACRO = 6

• NODE_TYPE_DOCS_MACRO = 7

• NODE_TYPE_ANALYSIS = 8

• NODE_TYPE_OPERATION = 9

• NODE_TYPE_EXPOSURE = 10

• NODE_TYPE_METRIC = 12

• NODE_TYPE_SAVED_QUERY = 13

• NODE_TYPE_SEMANTIC_MODEL = 14

• NODE_TYPE_FUNCTION = 15

Second-level outcome indicating whether a successfully-completed non-test node produced warnings. Analogous to TestOutcome for test nodes. Warnings are already emitted individually as LogMessages; this field exists only to signal the presence of warnings at the outcome level.

Used in: NodeEvaluationDetail

• NODE_WARNING_OUTCOME_UNSPECIFIED = 0

• NODE_WARNING_OUTCOME_NO_WARNINGS = 1

• NODE_WARNING_OUTCOME_WITH_WARNINGS = 2

Used in: NodeEvaluated, NodeProcessed

• SourceFreshnessOutcome node_freshness_outcome = 1

• optional int64 age_seconds = 2

  Age of the source in seconds (time since last load)

Freshness-specific outcome details (only for SOURCE nodes with freshness checks).

Used in: SourceFreshnessDetail

• SOURCE_FRESHNESS_OUTCOME_OUTCOME_PASSED = 0

  Freshness within acceptable (success) threshold.

• SOURCE_FRESHNESS_OUTCOME_OUTCOME_WARNED = 1

  Freshness exceeded warning threshold but below error threshold.

• SOURCE_FRESHNESS_OUTCOME_OUTCOME_FAILED = 2

  Freshness exceeded error threshold.

Used in: NodeEvaluated, NodeProcessed

• TestOutcome test_outcome = 1

• int32 failing_rows = 2

  Number of failing rows for this test.

• optional string diff_table = 4

  Pretty printed table diff if available.

• optional bool store_failures = 5

  Tell consumer whether or not the failure table exists.

Test-specific outcome details (only for TEST and UNITTEST node types).

Used in: TestEvaluationDetail

• TEST_OUTCOME_PASSED = 0

  No failures found or below warning threshold.

• TEST_OUTCOME_WARNED = 1

  Failures found between warning and error thresholds.

• TEST_OUTCOME_FAILED = 2

  Failures found above error threshold.