revise the property name to dbt_name

Author: themisvaltinos

sqlmesh/core/context.py

@@ -1678,9 +1678,9 @@ def plan_builder(
             console=self.console,
             user_provided_flags=user_provided_flags,
             selected_models={
-                node_name
+                dbt_name
                 for model in model_selector.expand_model_selections(select_models or "*")
-                if (node_name := snapshots[model].node.node_name)
+                if (dbt_name := snapshots[model].node.dbt_name)
             },
             explain=explain or False,
             ignore_cron=ignore_cron or False,

sqlmesh/core/node.py

@@ -199,7 +199,7 @@ class _Node(PydanticModel):
     interval_unit_: t.Optional[IntervalUnit] = Field(alias="interval_unit", default=None)
     tags: t.List[str] = []
     stamp: t.Optional[str] = None
-    node_name: t.Optional[str] = None  # dbt node name
+    dbt_name: t.Optional[str] = None  # dbt node name
     _path: t.Optional[Path] = None
     _data_hash: t.Optional[str] = None
     _metadata_hash: t.Optional[str] = None

sqlmesh/core/scheduler.py

@@ -812,7 +812,7 @@ def _run_or_audit(
             run_environment_statements=run_environment_statements,
             audit_only=audit_only,
             auto_restatement_triggers=auto_restatement_triggers,
-            selected_models={s.node.node_name for s in merged_intervals if s.node.node_name},
+            selected_models={s.node.dbt_name for s in merged_intervals if s.node.dbt_name},
         )
 
         return CompletionStatus.FAILURE if errors else CompletionStatus.SUCCESS

sqlmesh/dbt/model.py

@@ -689,7 +689,7 @@ def to_sqlmesh(
             extract_dependencies_from_query=False,
             allow_partials=allow_partials,
             virtual_environment_mode=virtual_environment_mode,
-            node_name=self.node_name,
+            dbt_name=self.node_name,
             **optional_kwargs,
             **model_kwargs,
         )

sqlmesh/dbt/seed.py

@@ -92,7 +92,7 @@ def to_sqlmesh(
             audit_definitions=audit_definitions,
             virtual_environment_mode=virtual_environment_mode,
             start=self.start or context.sqlmesh_config.model_defaults.start,
-            node_name=self.node_name,
+            dbt_name=self.node_name,
             **kwargs,
         )
 

sqlmesh/migrations/v0097_add_node_name.py …migrations/v0097_add_dbt_name_in_node.pysqlmesh/migrations/v0097_add_node_name.py renamed to sqlmesh/migrations/v0097_add_dbt_name_in_node.py sqlmesh/migrations/v0097_add_node_name.py renamed to sqlmesh/migrations/v0097_add_dbt_name_in_node.py

@@ -1,4 +1,4 @@
-"""Add 'node_name' property to node definition."""
+"""Add 'dbt_name' property to node definition."""
 
 
 def migrate_schemas(state_sync, **kwargs):  # type: ignore

tests/dbt/test_model.py

@@ -652,7 +652,7 @@ def test_node_name_populated_for_dbt_models(dbt_dummy_postgres_config: PostgresC
 
     # check after convert to SQLMesh model that node_name is populated correctly
     sqlmesh_model = model_config.to_sqlmesh(context)
-    assert sqlmesh_model.node_name == "model.test_package.test_model"
+    assert sqlmesh_model.dbt_name == "model.test_package.test_model"
 
 
 @pytest.mark.slow
@@ -709,4 +709,4 @@ def test_load_model_dbt_node_name(tmp_path: Path) -> None:
 
     # Verify that node_name is the equivalent dbt one
     model = context.snapshots[model_fqn].model
-    assert model.node_name == "model.test_project.simple_model"
+    assert model.dbt_name == "model.test_project.simple_model"