Pin sqlparse <0.5.5 (#12308)

* pin sqlparse <0.5.5

* upper bound sqlparse dependency

.changes/unreleased/Dependencies-20251219-153804.yaml

@@ -0,0 +1,6 @@
+kind: Dependencies
+body: Bump minimum click to 8.2.0
+time: 2025-12-19T15:38:04.785842-06:00
+custom:
+  Author: QMalcolm
+  Issue: "12305"

.changes/unreleased/Fixes-20251204-094753.yaml

@@ -0,0 +1,6 @@
+kind: Fixes
+body: ':bug: :snowman: Fix ref resolution within package when duplicate nodes exist, behind require_ref_searches_node_package_before_root behavior change flag'
+time: 2025-12-04T09:47:53.349428-08:00
+custom:
+    Author: michelleark
+    Issue: "11351"

.changes/unreleased/Fixes-20251216-120727.yaml

@@ -0,0 +1,6 @@
+kind: Fixes
+body: ':bug: :snowman:Propagate exceptions for NodeFinished callbacks in dbtRunner'
+time: 2025-12-16T12:07:27.576087-05:00
+custom:
+    Author: michelleark
+    Issue: "11612"

.changes/unreleased/Fixes-20251217-002813.yaml

@@ -0,0 +1,6 @@
+kind: Fixes
+body: Adds omitted return statement to RuntimeConfigObject.meta_require method
+time: 2025-12-17T00:28:13.015416197Z
+custom:
+    Author: mjsqu
+    Issue: "12288"

.changes/unreleased/Fixes-20251217-105918.yaml

@@ -0,0 +1,6 @@
+kind: Fixes
+body: Do not raise deprecation warning when encountering dataset or project configs for bigquery
+time: 2025-12-17T10:59:18.372968-05:00
+custom:
+    Author: michelleark
+    Issue: "12285"

.changes/unreleased/Fixes-20251219-184405.yaml

@@ -0,0 +1,6 @@
+kind: Fixes
+body: Pin sqlparse <0.5.5 to avoid max tokens issue
+time: 2025-12-19T18:44:05.216329-05:00
+custom:
+    Author: michelleark
+    Issue: "12303"

.changes/unreleased/Under the Hood-20250929-151159.yaml

@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Update schema file order test
+time: 2025-09-29T15:11:59.611595-04:00
+custom:
+    Author: gshank
+    Issue: "11869"

.changes/unreleased/Under the Hood-20251215-155046.yaml

@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Bump lower bound for dbt-common to 1.37.2
+time: 2025-12-15T15:50:46.857793-05:00
+custom:
+    Author: michelleark
+    Issue: "12284"

.github/dbt-postgres-testing.yml

@@ -108,62 +108,62 @@ jobs:
           echo "dbt-postgres-ref=${{ steps.core-ref.outputs.ref }}"
           echo "dbt-core-ref=${{ steps.common-ref.outputs.ref }}"
 
-  integration-tests-postgres:
-    name: "dbt-postgres integration tests"
-    needs: [job-prep]
-    runs-on: ubuntu-latest
-    defaults:
-      run:
-        working-directory: "./dbt-postgres"
-    environment:
-      name: "dbt-postgres"
-    env:
-      POSTGRES_TEST_HOST: ${{ vars.POSTGRES_TEST_HOST }}
-      POSTGRES_TEST_PORT: ${{ vars.POSTGRES_TEST_PORT }}
-      POSTGRES_TEST_USER: ${{ vars.POSTGRES_TEST_USER }}
-      POSTGRES_TEST_PASS: ${{ secrets.POSTGRES_TEST_PASS }}
-      POSTGRES_TEST_DATABASE: ${{ vars.POSTGRES_TEST_DATABASE }}
-      POSTGRES_TEST_THREADS: ${{ vars.POSTGRES_TEST_THREADS }}
-    services:
-      postgres:
-          image: postgres
-          env:
-            POSTGRES_PASSWORD: postgres
-          options: >-
-              --health-cmd pg_isready
-              --health-interval 10s
-              --health-timeout 5s
-              --health-retries 5
-          ports:
-            - ${{ vars.POSTGRES_TEST_PORT }}:5432
-    steps:
-      - name: "Check out dbt-adapters@${{ needs.job-prep.outputs.dbt-postgres-ref }}"
-        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # actions/checkout@v4
-        with:
-          repository: dbt-labs/dbt-adapters
-          ref: ${{ needs.job-prep.outputs.dbt-postgres-ref }}
+  # integration-tests-postgres:
+  #   name: "dbt-postgres integration tests"
+  #   needs: [job-prep]
+  #   runs-on: ubuntu-latest
+  #   defaults:
+  #     run:
+  #       working-directory: "./dbt-postgres"
+  #   environment:
+  #     name: "dbt-postgres"
+  #   env:
+  #     POSTGRES_TEST_HOST: ${{ vars.POSTGRES_TEST_HOST }}
+  #     POSTGRES_TEST_PORT: ${{ vars.POSTGRES_TEST_PORT }}
+  #     POSTGRES_TEST_USER: ${{ vars.POSTGRES_TEST_USER }}
+  #     POSTGRES_TEST_PASS: ${{ secrets.POSTGRES_TEST_PASS }}
+  #     POSTGRES_TEST_DATABASE: ${{ vars.POSTGRES_TEST_DATABASE }}
+  #     POSTGRES_TEST_THREADS: ${{ vars.POSTGRES_TEST_THREADS }}
+  #   services:
+  #     postgres:
+  #         image: postgres
+  #         env:
+  #           POSTGRES_PASSWORD: postgres
+  #         options: >-
+  #             --health-cmd pg_isready
+  #             --health-interval 10s
+  #             --health-timeout 5s
+  #             --health-retries 5
+  #         ports:
+  #           - ${{ vars.POSTGRES_TEST_PORT }}:5432
+  #   steps:
+  #     - name: "Check out dbt-adapters@${{ needs.job-prep.outputs.dbt-postgres-ref }}"
+  #       uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # actions/checkout@v4
+  #       with:
+  #         repository: dbt-labs/dbt-adapters
+  #         ref: ${{ needs.job-prep.outputs.dbt-postgres-ref }}
 
-      - name: "Set up Python"
-        uses: actions/setup-python@a26af69be951a213d495a4c3e4e4022e16d87065 # actions/setup-python@v5
-        with:
-            python-version: ${{ inputs.python-version }}
+  #     - name: "Set up Python"
+  #       uses: actions/setup-python@a26af69be951a213d495a4c3e4e4022e16d87065 # actions/setup-python@v5
+  #       with:
+  #           python-version: ${{ inputs.python-version }}
 
-      - name: "Set environment variables"
-        run: |
-            echo "HATCH_PYTHON=${{ inputs.python-version }}" >> $GITHUB_ENV
-            echo "PIP_ONLY_BINARY=psycopg2-binary" >> $GITHUB_ENV
+  #     - name: "Set environment variables"
+  #       run: |
+  #           echo "HATCH_PYTHON=${{ inputs.python-version }}" >> $GITHUB_ENV
+  #           echo "PIP_ONLY_BINARY=psycopg2-binary" >> $GITHUB_ENV
 
-      - name: "Setup test database"
-        run: psql -f ./scripts/setup_test_database.sql
-        env:
-            PGHOST: ${{ vars.POSTGRES_TEST_HOST }}
-            PGPORT: ${{ vars.POSTGRES_TEST_PORT }}
-            PGUSER: postgres
-            PGPASSWORD: postgres
-            PGDATABASE: postgres
+  #     - name: "Setup test database"
+  #       run: psql -f ./scripts/setup_test_database.sql
+  #       env:
+  #           PGHOST: ${{ vars.POSTGRES_TEST_HOST }}
+  #           PGPORT: ${{ vars.POSTGRES_TEST_PORT }}
+  #           PGUSER: postgres
+  #           PGPASSWORD: postgres
+  #           PGDATABASE: postgres
 
-      - name: "Install hatch"
-        uses: pypa/hatch@257e27e51a6a5616ed08a39a408a21c35c9931bc # pypa/hatch@install
+  #     - name: "Install hatch"
+  #       uses: pypa/hatch@257e27e51a6a5616ed08a39a408a21c35c9931bc # pypa/hatch@install
 
-      - name: "Run integration tests"
-        run: hatch run ${{ inputs.hatch-env }}:integration-tests
+  #     - name: "Run integration tests"
+  #       run: hatch run ${{ inputs.hatch-env }}:integration-tests

.github/workflows/main.yml

@@ -62,7 +62,7 @@ jobs:
           python -m pip --version
           python -m pip install hatch
           cd core
-          hatch run setup
+          hatch -v run setup
 
       - name: Verify dbt installation
         run: |
@@ -106,7 +106,7 @@ jobs:
         with:
           timeout_minutes: 10
           max_attempts: 3
-          command: cd core && hatch run ci:unit-tests
+          command: cd core && hatch -v run ci:unit-tests
 
       - name: Get current date
         if: always()
@@ -230,7 +230,7 @@ jobs:
           timeout_minutes: 30
           max_attempts: 3
           shell: bash
-          command: cd core && hatch run ci:integration-tests -- --ddtrace --splits ${{ env.PYTHON_INTEGRATION_TEST_WORKERS }} --group ${{ matrix.split-group }}
+          command: cd core && hatch -v run ci:integration-tests -- --ddtrace --splits ${{ env.PYTHON_INTEGRATION_TEST_WORKERS }} --group ${{ matrix.split-group }}
 
       - name: Get current date
         if: always()
@@ -311,7 +311,7 @@ jobs:
           timeout_minutes: 30
           max_attempts: 3
           shell: bash
-          command: cd core && hatch run ci:integration-tests -- --ddtrace --splits ${{ env.PYTHON_INTEGRATION_TEST_WORKERS }} --group ${{ matrix.split-group }}
+          command: cd core && hatch -v run ci:integration-tests -- --ddtrace --splits ${{ env.PYTHON_INTEGRATION_TEST_WORKERS }} --group ${{ matrix.split-group }}
 
       - name: Get current date
         if: always()
@@ -326,7 +326,7 @@ jobs:
           name: logs_${{ matrix.python-version }}_${{ matrix.os }}_${{ matrix.split-group }}_${{ steps.date.outputs.date }}
           path: ./logs
 
-      - name: Upload Integration Test Coverage to Codecov
+      - name: Upload Integration Test Coverage
         if: ${{ matrix.python-version == '3.11' }}
         uses: codecov/codecov-action@5a1091511ad55cbe89839c7260b706298ca349f7 # codecov/codecov-action@v5
         with:
@@ -380,4 +380,4 @@ jobs:
       - name: Check and verify distributions
         run: |
           cd core
-          hatch run build:check-all
+          hatch -v run build:check-all

.github/workflows/nightly-release.yml

@@ -62,7 +62,7 @@ jobs:
       - name: "Generate Nightly Release Version Number"
         id: nightly-release-version
         run: |
-          number="${{ steps.semver.outputs.version }}.dev${{ steps.current-date.outputs.date }}"
+          number="${{ steps.semver.outputs.version }}.post${{ steps.current-date.outputs.date }}"
           echo "number=$number" >> $GITHUB_OUTPUT
 
       - name: "Audit Nightly Release Version And Parse Into Parts"

.github/workflows/structured-logging-schema-check.yml

@@ -123,7 +123,7 @@ jobs:
         with:
           timeout_minutes: 30
           max_attempts: 3
-          command: cd core && hatch run ci:integration-tests -- -nauto
+          command: cd core && hatch -v run ci:integration-tests -- -nauto
         env:
           PYTEST_ADDOPTS: ${{ format('--splits {0} --group {1}', env.PYTHON_INTEGRATION_TEST_WORKERS, matrix.split-group) }}
 

core/dbt/context/providers.py

@@ -608,6 +608,8 @@ class RuntimeConfigObject(Config):
         if validator is not None:
             self._validate(validator, to_return)
 
+        return to_return
+
     def get(self, name, default=None, validator=None):
         to_return = self._lookup(name, default)
 

core/dbt/contracts/graph/manifest.py

@@ -558,7 +558,10 @@ def _packages_to_search(
     elif current_project == node_package:
         return [current_project, None]
     else:
-        return [current_project, node_package, None]
+        if get_flags().require_ref_searches_node_package_before_root:
+            return [node_package, current_project, None]
+        else:
+            return [current_project, node_package, None]
 
 
 def _sort_values(dct):

core/dbt/contracts/project.py

@@ -367,6 +367,7 @@ class ProjectFlags(ExtensibleDbtClassMixin):
     require_all_warnings_handled_by_warn_error: bool = False
     require_generic_test_arguments_property: bool = True
     require_unique_project_resource_names: bool = False
+    require_ref_searches_node_package_before_root: bool = False
 
     @property
     def project_only_flags(self) -> Dict[str, Any]:
@@ -384,6 +385,7 @@ class ProjectFlags(ExtensibleDbtClassMixin):
             "require_all_warnings_handled_by_warn_error": self.require_all_warnings_handled_by_warn_error,
             "require_generic_test_arguments_property": self.require_generic_test_arguments_property,
             "require_unique_project_resource_names": self.require_unique_project_resource_names,
+            "require_ref_searches_node_package_before_root": self.require_ref_searches_node_package_before_root,
         }
 
 

core/dbt/events/types.py

@@ -1270,6 +1270,19 @@ class InvalidMacroAnnotation(WarnLevel):
         return self.msg
 
 
+class PackageNodeDependsOnRootProjectNode(WarnLevel):
+    def code(self) -> str:
+        return "I077"
+
+    def message(self) -> str:
+        msg = (
+            f"The node '{self.node_name}'in package '{self.package_name}' depends on the root project node '{self.root_project_unique_id}'."
+            "This may lead to unexpected cycles downstream. Please set the 'require_ref_prefers_node_package_to_root' behavior change flag to True to avoid this issue."
+            "For more information, see the documentation at https://docs.getdbt.com/reference/global-configs/behavior-changes#require_ref_prefers_node_package_to_root"
+        )
+        return warning_tag(msg)
+
+
 # =======================================================
 # M - Deps generation
 # =======================================================

core/dbt/jsonschemas/jsonschemas.py

@@ -37,6 +37,10 @@ _HIERARCHICAL_CONFIG_KEYS = {
     "unit_tests",
 }
 
+_ADAPTER_TO_CONFIG_ALIASES = {
+    "bigquery": ["dataset", "project"],
+}
+
 
 def load_json_from_package(jsonschema_type: str, filename: str) -> Dict[str, Any]:
     """Loads a JSON file from within a package."""
@@ -106,6 +110,16 @@ def _validate_with_schema(
     return validator.iter_errors(json)
 
 
+def _get_allowed_config_key_aliases() -> List[str]:
+    config_aliases = []
+    invocation_context = get_invocation_context()
+    for adapter in invocation_context.adapter_types:
+        if adapter in _ADAPTER_TO_CONFIG_ALIASES:
+            config_aliases.extend(_ADAPTER_TO_CONFIG_ALIASES[adapter])
+
+    return config_aliases
+
+
 def _get_allowed_config_fields_from_error_path(
     yml_schema: Dict[str, Any], error_path: List[Union[str, int]]
 ) -> Optional[List[str]]:
@@ -135,6 +149,7 @@ def _get_allowed_config_fields_from_error_path(
     ][0]["$ref"].split("/")[-1]
 
     allowed_config_fields = list(set(yml_schema["definitions"][config_field_name]["properties"]))
+    allowed_config_fields.extend(_get_allowed_config_key_aliases())
 
     return allowed_config_fields
 
@@ -169,7 +184,6 @@ def jsonschema_validate(schema: Dict[str, Any], json: Dict[str, Any], file_path:
                         continue
 
                     if key == "overrides" and key_path.startswith("sources"):
-
                         deprecations.warn(
                             "source-override-deprecation",
                             source_name=key_path.split(".")[-1],
@@ -205,6 +219,9 @@ def jsonschema_validate(schema: Dict[str, Any], json: Dict[str, Any], file_path:
                         keys = _additional_properties_violation_keys(sub_error)
                         key_path = error_path_to_string(error)
                         for key in keys:
+                            if key in _get_allowed_config_key_aliases():
+                                continue
+
                             deprecations.warn(
                                 "custom-key-in-config-deprecation",
                                 key=key,

core/dbt/parser/manifest.py

@@ -77,6 +77,7 @@ from dbt.events.types import (
     InvalidDisabledTargetInTestNode,
     MicrobatchModelNoEventTimeInputs,
     NodeNotFoundOrDisabled,
+    PackageNodeDependsOnRootProjectNode,
     ParsedFileLoadFailed,
     ParsePerfInfoPath,
     PartialParsingError,
@@ -1636,6 +1637,33 @@ def invalid_target_fail_unless_test(
         )
 
 
+def warn_if_package_node_depends_on_root_project_node(
+    node: ManifestNode,
+    target_model: ManifestNode,
+    ref_package_name: Optional[str],
+    current_project: str,
+) -> None:
+    """
+    Args:
+        node: The node that specifies the ref
+        target_model: The node that is being ref'd to
+        ref_package_name: The package name specified in the ref
+        current_project: The root project
+    """
+    if (
+        node.package_name != current_project
+        and target_model.package_name == current_project
+        and ref_package_name != current_project
+    ):
+        warn_or_error(
+            PackageNodeDependsOnRootProjectNode(
+                node_name=node.name,
+                package_name=node.package_name,
+                root_project_unique_id=target_model.unique_id,
+            )
+        )
+
+
 def _build_model_names_to_versions(manifest: Manifest) -> Dict[str, Dict]:
     model_names_to_versions: Dict[str, Dict] = {}
     for node in manifest.nodes.values():
@@ -1893,6 +1921,11 @@ def _process_refs(
                 scope=target_model.package_name,
             )
 
+        if not get_flags().require_ref_searches_node_package_before_root:
+            warn_if_package_node_depends_on_root_project_node(
+                node, target_model, ref.package, current_project
+            )
+
         target_model_id = target_model.unique_id
         node.depends_on.add_node(target_model_id)
 

core/dbt/task/runnable.py

@@ -249,34 +249,17 @@ class GraphRunnableTask(ConfiguredTask):
                 thread_exception = e
             finally:
                 if result is not None:
-                    fire_event(
-                        NodeFinished(
-                            node_info=runner.node.node_info,
-                            run_result=result.to_msg_dict(),
+                    try:
+                        fire_event(
+                            NodeFinished(
+                                node_info=runner.node.node_info,
+                                run_result=result.to_msg_dict(),
+                            )
                         )
-                    )
+                    except Exception as e:
+                        result = self._handle_thread_exception(runner, e)
                 else:
-                    msg = f"Exception on worker thread. {thread_exception}"
-
-                    fire_event(
-                        GenericExceptionOnRun(
-                            unique_id=runner.node.unique_id,
-                            exc=str(thread_exception),
-                            node_info=runner.node.node_info,
-                        )
-                    )
-
-                    result = RunResult(
-                        status=RunStatus.Error,  # type: ignore
-                        timing=[],
-                        thread_id="",
-                        execution_time=0.0,
-                        adapter_response={},
-                        message=msg,
-                        failures=None,
-                        batch_results=None,
-                        node=runner.node,
-                    )
+                    result = self._handle_thread_exception(runner, thread_exception)
 
             # `_event_status` dict is only used for logging.  Make sure
             # it gets deleted when we're done with it
@@ -365,6 +348,32 @@ class GraphRunnableTask(ConfiguredTask):
         args = [runner]
         self._submit(pool, args, callback)
 
+    def _handle_thread_exception(
+        self,
+        runner: BaseRunner,
+        thread_exception: Optional[Union[KeyboardInterrupt, SystemExit, Exception]],
+    ) -> RunResult:
+        msg = f"Exception on worker thread. {thread_exception}"
+        fire_event(
+            GenericExceptionOnRun(
+                unique_id=runner.node.unique_id,
+                exc=str(thread_exception),
+                node_info=runner.node.node_info,
+            )
+        )
+
+        return RunResult(
+            status=RunStatus.Error,  # type: ignore
+            timing=[],
+            thread_id="",
+            execution_time=0.0,
+            adapter_response={},
+            message=msg,
+            failures=None,
+            batch_results=None,
+            node=runner.node,
+        )
+
     def _handle_result(self, result: RunResult) -> None:
         """Mark the result as completed, insert the `CompileResultNode` into
         the manifest, and mark any descendants (potentially with a 'cause' if

core/pyproject.toml

@@ -37,7 +37,7 @@ dependencies = [
     # ----
     # dbt-core uses these packages in standard ways. Pin to the major version, and check compatibility
     # with major versions in each new minor version of dbt-core.
-    "click>=8.0.2,<9.0",
+    "click>=8.2.0,<9.0",
     "jsonschema>=4.19.1,<5.0",
     "networkx>=2.3,<4.0",
     "protobuf>=6.0,<7.0",
@@ -47,14 +47,14 @@ dependencies = [
     # These packages are major-version-0. Keep upper bounds on upcoming minor versions (which could have breaking changes)
     # and check compatibility / bump in each new minor version of dbt-core.
     "pathspec>=0.9,<0.13",
-    "sqlparse>=0.5.0,<0.6.0",
+    "sqlparse>=0.5.0,<0.5.5",
     # ----
     # These are major-version-0 packages also maintained by dbt-labs.
     # Accept patches but avoid automatically updating past a set minor version range.
     "dbt-extractor>=0.5.0,<=0.6",
     "dbt-semantic-interfaces>=0.9.0,<0.10",
     # Minor versions for these are expected to be backwards-compatible
-    "dbt-common>=1.37.0,<2.0",
+    "dbt-common>=1.37.2,<2.0",
     "dbt-adapters>=1.15.5,<2.0",
     "dbt-protos>=1.0.405,<2.0",
     "pydantic<3",

tests/functional/configs/test_get_default.py

@@ -33,7 +33,7 @@ select {{ config.require('meta_key') }} as col_value
 
 meta_model_meta_require_sql = """
 -- models/meta_model.sql
-select {{ config.require('meta_key') }} as col_value
+select {{ config.meta_require('meta_key') }} as col_value
 """
 
 
@@ -66,11 +66,11 @@ class TestConfigGetMeta:
         self,
         project,
     ):
-        # This test runs a model with a config.get(key, default)
+        # This test runs a model with a config.get(key, default) -> default value returned
         results = run_dbt(["run"], expect_pass=False)
         assert len(results) == 1
         assert str(results[0].status) == "error"
-        assert 'column "my_meta_value" does not exist' in results[0].message
+        assert 'column "meta_default_value" does not exist' in results[0].message
 
         write_file(meta_model_meta_get_sql, "models", "meta_model.sql")
         results = run_dbt(["run"], expect_pass=False)
@@ -95,7 +95,7 @@ class TestConfigGetMetaRequire:
         results = run_dbt(["run"], expect_pass=False)
         assert len(results) == 1
         assert str(results[0].status) == "error"
-        assert 'column "my_meta_value" does not exist' in results[0].message
+        assert "does not define a required config parameter 'meta_key'" in results[0].message
 
         write_file(meta_model_meta_require_sql, "models", "meta_model.sql")
         results = run_dbt(["run"], expect_pass=False)

tests/functional/dbt_runner/test_dbt_runner.py

@@ -55,6 +55,22 @@ class TestDbtRunner:
         dbt.invoke(["debug"])
         mock_callback.assert_called()
 
+    def test_callback_node_finished_exceptions_are_raised(self, project):
+        from dbt_common.events.base_types import EventMsg
+
+        def callback_with_exception(event: EventMsg):
+            if event.info.name == "NodeFinished":
+                raise Exception("This should let continue the execution registering the failure")
+
+        dbt = dbtRunner(callbacks=[callback_with_exception])
+        result = dbt.invoke(["run", "--select", "models"])
+
+        assert result is not None
+        assert (
+            result.result.results[0].message
+            == "Exception on worker thread. This should let continue the execution registering the failure"
+        )
+
     def test_invoke_kwargs(self, project, dbt):
         res = dbt.invoke(
             ["run"],

tests/functional/dependencies/inverted_ref_dependency/dbt_project.yml

@@ -0,0 +1,22 @@
+name: 'inverted_ref_dependency'
+version: '1.0'
+config-version: 2
+
+profile: 'default'
+
+model-paths: ["models"]
+analysis-paths: ["analyses"]
+test-paths: ["tests"]
+seed-paths: ["seeds"]
+macro-paths: ["macros"]
+
+require-dbt-version: '>=0.1.0'
+
+target-path: "target"  # directory which will store compiled SQL files
+clean-targets:         # directories to be removed by `dbt clean`
+    - "target"
+    - "dbt_packages"
+
+
+seeds:
+  quote_columns: False

tests/functional/dependencies/inverted_ref_dependency/models/a.sql

@@ -0,0 +1,3 @@
+{{ config(alias='package_a')}}
+
+select 1 as id

tests/functional/dependencies/inverted_ref_dependency/models/b.sql

@@ -0,0 +1 @@
+select * from {{ ref('a') }}

tests/functional/dependencies/inverted_ref_dependency/models/b_root_package_in_ref.sql

@@ -0,0 +1 @@
+select * from {{ ref('test', 'a') }}

tests/functional/dependencies/test_dependency_inverted_ref.py

@@ -0,0 +1,78 @@
+import shutil
+from pathlib import Path
+
+import pytest
+
+from dbt.events.types import PackageNodeDependsOnRootProjectNode
+from dbt.tests.util import run_dbt
+from dbt_common.events.event_catcher import EventCatcher
+
+
+class BaseInvertedRefDependencyTest(object):
+    @pytest.fixture(scope="class")
+    def models(self):
+        return {
+            "a.sql": "select 1 as id",
+        }
+
+    @pytest.fixture(scope="class", autouse=True)
+    def setUp(self, project):
+        shutil.copytree(
+            project.test_dir / Path("inverted_ref_dependency"),
+            project.project_root / Path("inverted_ref_dependency"),
+        )
+
+    @pytest.fixture(scope="class")
+    def packages(self):
+        return {"packages": [{"local": "inverted_ref_dependency"}]}
+
+
+class TestInvertedRefDependency(BaseInvertedRefDependencyTest):
+    @pytest.fixture(scope="class")
+    def project_config_update(self):
+        return {
+            "flags": {
+                "require_ref_searches_node_package_before_root": True,
+            }
+        }
+
+    def test_inverted_ref_dependency(self, project):
+        event_catcher = EventCatcher(PackageNodeDependsOnRootProjectNode)
+        run_dbt(["deps"])
+
+        manifest = run_dbt(["parse"], callbacks=[event_catcher.catch])
+
+        assert len(manifest.nodes) == 4
+        # Correct behavior - package node depends on node from same package
+        assert manifest.nodes["model.inverted_ref_dependency.b"].depends_on.nodes == [
+            "model.inverted_ref_dependency.a"
+        ]
+        # If a package explicitly references a root project node, it still resolves to root project
+        manifest.nodes["model.inverted_ref_dependency.b_root_package_in_ref"].depends_on.nodes == [
+            "model.test.a"
+        ]
+
+        # No inverted ref warning raised
+        assert len(event_catcher.caught_events) == 0
+
+
+class TestInvertedRefDependencyLegacy(BaseInvertedRefDependencyTest):
+    def test_inverted_ref_dependency(self, project):
+        event_catcher = EventCatcher(PackageNodeDependsOnRootProjectNode)
+        run_dbt(["deps"])
+
+        manifest = run_dbt(["parse"], callbacks=[event_catcher.catch])
+
+        assert len(manifest.nodes) == 4
+        # Legacy behavior - package node depends on node from root project
+        assert manifest.nodes["model.inverted_ref_dependency.b"].depends_on.nodes == [
+            "model.test.a"
+        ]
+        assert manifest.nodes[
+            "model.inverted_ref_dependency.b_root_package_in_ref"
+        ].depends_on.nodes == ["model.test.a"]
+
+        # Inverted ref warning raised - only for b, not b_root_package_in_ref
+        assert len(event_catcher.caught_events) == 1
+        assert event_catcher.caught_events[0].data.node_name == "b"
+        assert event_catcher.caught_events[0].data.package_name == "inverted_ref_dependency"

tests/functional/partial_parsing/test_pp_schema_file_order.py

@@ -220,10 +220,16 @@ models_yml = """
 models:
   - name: abcd
     description: "abcd model"
+    versions:
+      - v: 1
   - name: efgh
     description: "efgh model"
+    versions:
+      - v: 1
   - name: ijkl
     description: "ijkl model"
+    versions:
+      - v: 1
 """
 
 append_sources_yml = """
@@ -233,6 +239,8 @@ append_sources_yml = """
 append_models_yml = """
   - name: mnop
     description: "mnop model"
+    versions:
+      - v: 1
 """
 
 mnop_sql = """
@@ -245,9 +253,9 @@ class TestSourcesAndSchemaFiles:
     def models(self):
         return {
             "sources.yml": sources_yml,
-            "abcd.sql": abcd_sql,
-            "efgh.sql": efgh_sql,
-            "ijkl.sql": ijkl_sql,
+            "abcd_v1.sql": abcd_sql,
+            "efgh_v1.sql": efgh_sql,
+            "ijkl_v1.sql": ijkl_sql,
             "_models.yml": models_yml,
         }
 
@@ -258,7 +266,7 @@ class TestSourcesAndSchemaFiles:
         assert len(manifest.nodes) == 3
 
         write_file(models_yml + append_models_yml, project.project_root, "models", "_models.yml")
-        write_file(mnop_sql, project.project_root, "models", "mnop.sql")
+        write_file(mnop_sql, project.project_root, "models", "mnop_v1.sql")
         write_file(sources_yml + append_sources_yml, project.project_root, "models", "sources.yml")
 
         manifest = run_dbt(["parse"])
@@ -268,3 +276,4 @@ class TestSourcesAndSchemaFiles:
         # the patch updates, including description, so description will be ""
         for node in manifest.nodes.values():
             assert node.description == f"{node.name} model"
+            assert node.unique_id.endswith(".v1")

tests/unit/contracts/graph/test_manifest.py

@@ -10,7 +10,6 @@ from unittest import mock
 import freezegun
 import pytest
 
-import dbt.flags
 import dbt.version
 import dbt_common.invocation
 from dbt import tracking
@@ -1788,6 +1787,19 @@ def _ambiguous_ref_parameter_sets():
     return sets
 
 
+def _duplicate_node_name_across_packages_ref_parameter_sets():
+    sets = [
+        FindNodeSpec(
+            nodes=[MockNode("project_a", "my_model"), MockNode("root", "my_model")],
+            sources=[],
+            package=None,
+            version=None,
+            expected=("project_a", "my_model"),
+        ),
+    ]
+    return sets
+
+
 def id_nodes(arg):
     if isinstance(arg, list):
         node_names = "__".join(f"{n.package_name}_{n.search_name}" for n in arg)
@@ -1849,6 +1861,60 @@ def test_resolve_ref_ambiguous_resource_name_across_packages(
         )
 
 
+@pytest.mark.parametrize(
+    "nodes,sources,package,version,expected",
+    _duplicate_node_name_across_packages_ref_parameter_sets(),
+    ids=id_nodes,
+)
+def test_resolve_ref_with_node_package_legacy(nodes, sources, package, version, expected):
+    set_from_args(
+        Namespace(
+            SEND_ANONYMOUS_USAGE_STATS=False,
+            REQUIRE_REF_SEARCHES_NODE_PACKAGE_BEFORE_ROOT=False,
+        ),
+        None,
+    )
+    manifest = make_manifest(nodes=nodes, sources=sources)
+    result = manifest.resolve_ref(
+        source_node=None,
+        target_model_name="my_model",
+        target_model_package=package,
+        target_model_version=version,
+        current_project="root",
+        node_package="project_a",
+    )
+
+    assert result.name == "my_model"
+    assert result.package_name == "root"
+
+
+@pytest.mark.parametrize(
+    "nodes,sources,package,version,expected",
+    _duplicate_node_name_across_packages_ref_parameter_sets(),
+    ids=id_nodes,
+)
+def test_resolve_ref_with_node_package(nodes, sources, package, version, expected):
+    set_from_args(
+        Namespace(
+            SEND_ANONYMOUS_USAGE_STATS=False,
+            REQUIRE_REF_SEARCHES_NODE_PACKAGE_BEFORE_ROOT=True,
+        ),
+        None,
+    )
+    manifest = make_manifest(nodes=nodes, sources=sources)
+    result = manifest.resolve_ref(
+        source_node=None,
+        target_model_name="my_model",
+        target_model_package=package,
+        target_model_version=version,
+        current_project="root",
+        node_package="project_a",
+    )
+
+    assert result.name == "my_model"
+    assert result.package_name == "project_a"
+
+
 def _source_parameter_sets():
     sets = [
         # empties
@@ -1931,6 +1997,13 @@ def _source_parameter_sets():
     ids=id_nodes,
 )
 def test_resolve_source(nodes, sources, package, version, expected):
+    set_from_args(
+        Namespace(
+            SEND_ANONYMOUS_USAGE_STATS=False,
+            REQUIRE_REF_SEARCHES_NODE_PACKAGE_BEFORE_ROOT=False,
+        ),
+        None,
+    )
     manifest = make_manifest(nodes=nodes, sources=sources)
     result = manifest.resolve_source(
         target_source_name="my_source",

tests/unit/test_events.py

@@ -311,6 +311,9 @@ sample_values = [
     core_types.MicrobatchModelNoEventTimeInputs(model_name=""),
     core_types.InvalidConcurrentBatchesConfig(num_models=1, adapter_type=""),
     core_types.InvalidMacroAnnotation(msg="", macro_file_path="", macro_unique_id=""),
+    core_types.PackageNodeDependsOnRootProjectNode(
+        node_name="", node_package="", root_project_unique_id=""
+    ),
     # M - Deps generation ======================
     core_types.GitSparseCheckoutSubdirectory(subdir=""),
     core_types.GitProgressCheckoutRevision(revision=""),

tests/unit/test_jsonschemas.py

@@ -1,9 +1,17 @@
+import pytest
+
 from dbt.deprecations import (
     CustomKeyInConfigDeprecation,
     CustomKeyInObjectDeprecation,
     GenericJSONSchemaValidationDeprecation,
+    active_deprecations,
+    reset_deprecations,
+)
+from dbt.jsonschemas.jsonschemas import (
+    jsonschema_validate,
+    resources_schema,
+    validate_model_config,
 )
-from dbt.jsonschemas.jsonschemas import validate_model_config
 from dbt.tests.util import safe_set_invocation_context
 from dbt_common.context import get_invocation_context
 from dbt_common.events.event_catcher import EventCatcher
@@ -48,3 +56,38 @@ class TestValidateModelConfigNoError:
         assert len(ckicd_catcher.caught_events) == 1
         assert ckicd_catcher.caught_events[0].data.key == "non_existent_config"
         assert len(gjsvd_catcher.caught_events) == 0
+
+
+class TestValidateJsonSchema:
+    @pytest.fixture(scope="class")
+    def model_bigquery_alias_config_contents(self):
+        return {
+            "models": [
+                {
+                    "name": "model_1",
+                    "config": {
+                        "dataset": "dataset_1",
+                        "project": "project_1",
+                    },
+                }
+            ],
+        }
+
+    def test_validate_json_schema_no_error_aliases(self, model_bigquery_alias_config_contents):
+        reset_deprecations()
+
+        safe_set_invocation_context()
+        get_invocation_context().uses_adapter("bigquery")
+
+        jsonschema_validate(resources_schema(), model_bigquery_alias_config_contents, "test.yml")
+        assert active_deprecations == {}
+
+    def test_validate_json_schema_has_error_aliases(self, model_bigquery_alias_config_contents):
+        reset_deprecations()
+
+        safe_set_invocation_context()
+        # Set to adapter that doesn't support aliases specified
+        get_invocation_context().uses_adapter("snowflake")
+
+        jsonschema_validate(resources_schema(), model_bigquery_alias_config_contents, "test.yml")
+        assert active_deprecations == {"custom-key-in-config-deprecation": 2}