finish rename

replace MacroResolver with MacroClient
changelog entry
2025-12-17 19:31:34 +00:00 · 2023-12-08 09:30:50 +09:00 · 2023-12-08 01:40:14 +09:00 · 2023-12-08 00:49:26 +09:00 · 2023-12-08 00:39:43 +09:00 · 2023-12-08 00:26:18 +09:00
647 changed files with 50227 additions and 11459 deletions
--- a/.bumpversion.cfg
+++ b/.bumpversion.cfg
@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 1.7.0a1
+current_version = 1.8.0a1
 parse = (?P<major>[\d]+) # major version number
 	\.(?P<minor>[\d]+) # minor version number
 	\.(?P<patch>[\d]+) # patch version number
--- a/.changes/0.0.0.md
+++ b/.changes/0.0.0.md
@@ -3,6 +3,7 @@
 For information on prior major and minor releases, see their changelogs:


+* [1.7](https://github.com/dbt-labs/dbt-core/blob/1.7.latest/CHANGELOG.md)
 * [1.6](https://github.com/dbt-labs/dbt-core/blob/1.6.latest/CHANGELOG.md)
 * [1.5](https://github.com/dbt-labs/dbt-core/blob/1.5.latest/CHANGELOG.md)
 * [1.4](https://github.com/dbt-labs/dbt-core/blob/1.4.latest/CHANGELOG.md)
--- a/Changes-20231127-114757.yaml
+++ b/Changes-20231127-114757.yaml
@@ -0,0 +1,6 @@
+kind: Breaking Changes
+body: Remove adapter.get_compiler interface
+time: 2023-11-27T11:47:57.443202-05:00
+custom:
+  Author: michelleark
+  Issue: "9148"
--- a/Changes-20231128-134356.yaml
+++ b/Changes-20231128-134356.yaml
@@ -0,0 +1,6 @@
+kind: Breaking Changes
+body: Move AdapterLogger to adapters folder
+time: 2023-11-28T13:43:56.853925-08:00
+custom:
+  Author: colin-rogers-dbt
+  Issue: "9151"
--- a/Changes-20231130-135348.yaml
+++ b/Changes-20231130-135348.yaml
@@ -0,0 +1,7 @@
+kind: Breaking Changes
+body: move event manager setup back to core, remove ref to global EVENT_MANAGER and
+  clean up event manager functions
+time: 2023-11-30T13:53:48.645192-08:00
+custom:
+  Author: colin-rogers-dbt
+  Issue: "9150"
--- a/.changes/unreleased/Dependencies-20231031-131954.yaml
+++ b/.changes/unreleased/Dependencies-20231031-131954.yaml
@@ -0,0 +1,6 @@
+kind: Dependencies
+body: Begin using DSI 0.4.x
+time: 2023-10-31T13:19:54.750009-07:00
+custom:
+  Author: QMalcolm peterallenwebb
+  PR: "8892"
--- a/.changes/unreleased/Dependencies-20231106-130051.yaml
+++ b/.changes/unreleased/Dependencies-20231106-130051.yaml
@@ -0,0 +1,6 @@
+kind: Dependencies
+body: Update typing-extensions version to >=4.4
+time: 2023-11-06T13:00:51.062386-08:00
+custom:
+  Author: tlento
+  PR: "9012"
--- a/.changes/unreleased/Docs-20230531-115419.yaml
+++ b/.changes/unreleased/Docs-20230531-115419.yaml
@@ -1,6 +0,0 @@
-kind: Docs
-body: Fix for column tests not rendering on quoted columns
-time: 2023-05-31T11:54:19.687363-04:00
-custom:
-  Author: drewbanin
-  Issue: "201"
--- a/.changes/unreleased/Docs-20230718-192422.yaml
+++ b/.changes/unreleased/Docs-20230718-192422.yaml
@@ -1,6 +0,0 @@
-kind: Docs
-body: Remove static SQL codeblock for metrics
-time: 2023-07-18T19:24:22.155323+02:00
-custom:
-  Author: marcodamore
-  Issue: "436"
--- a/.changes/unreleased/Docs-20231106-123157.yaml
+++ b/.changes/unreleased/Docs-20231106-123157.yaml
@@ -0,0 +1,6 @@
+kind: Docs
+body: fix get_custom_database docstring
+time: 2023-11-06T12:31:57.525711Z
+custom:
+  Author: LeoTheGriff
+  Issue: "9003"
--- a/.changes/unreleased/Features-20230915-123733.yaml
+++ b/.changes/unreleased/Features-20230915-123733.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: 'Allow adapters to include package logs in dbt standard logging '
+time: 2023-09-15T12:37:33.862862-07:00
+custom:
+  Author: colin-rogers-dbt
+  Issue: "7859"
--- a/.changes/unreleased/Features-20231017-143620.yaml
+++ b/.changes/unreleased/Features-20231017-143620.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: Add drop_schema_named macro
+time: 2023-10-17T14:36:20.612289-07:00
+custom:
+  Author: colin-rogers-dbt
+  Issue: "8025"
--- a/.changes/unreleased/Features-20231026-110821.yaml
+++ b/.changes/unreleased/Features-20231026-110821.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: migrate utils to common and adapters folders
+time: 2023-10-26T11:08:21.458709-07:00
+custom:
+  Author: colin-rogers-dbt
+  Issue: "8924"
--- a/.changes/unreleased/Features-20231026-123556.yaml
+++ b/.changes/unreleased/Features-20231026-123556.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: Move Agate helper client into common
+time: 2023-10-26T12:35:56.538587-07:00
+custom:
+  Author: MichelleArk
+  Issue: "8926"
--- a/.changes/unreleased/Features-20231026-123913.yaml
+++ b/.changes/unreleased/Features-20231026-123913.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: remove usage of dbt.config.PartialProject from dbt/adapters
+time: 2023-10-26T12:39:13.904116-07:00
+custom:
+  Author: MichelleArk
+  Issue: "8928"
--- a/.changes/unreleased/Features-20231031-132022.yaml
+++ b/.changes/unreleased/Features-20231031-132022.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: Add exports to SavedQuery spec
+time: 2023-10-31T13:20:22.448158-07:00
+custom:
+  Author: QMalcolm peterallenwebb
+  Issue: "8892"
--- a/.changes/unreleased/Features-20231107-135635.yaml
+++ b/.changes/unreleased/Features-20231107-135635.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: Remove legacy logger
+time: 2023-11-07T13:56:35.186648-08:00
+custom:
+  Author: colin-rogers-dbt
+  Issue: "8027"
--- a/.changes/unreleased/Features-20231110-154255.yaml
+++ b/.changes/unreleased/Features-20231110-154255.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: Support setting export configs hierarchically via saved query and project configs
+time: 2023-11-10T15:42:55.042317-08:00
+custom:
+  Author: QMalcolm
+  Issue: "8956"
--- a/.changes/unreleased/Features-20231116-234049.yaml
+++ b/.changes/unreleased/Features-20231116-234049.yaml
@@ -0,0 +1,6 @@
+kind: Features
+body: Support --empty flag for schema-only dry runs
+time: 2023-11-16T23:40:49.96651-05:00
+custom:
+  Author: michelleark
+  Issue: "8971"
--- a/.changes/unreleased/Fixes-20230718-125518.yaml
+++ b/.changes/unreleased/Fixes-20230718-125518.yaml
@@ -1,6 +0,0 @@
-kind: Fixes
-body: Enable converting deprecation warnings to errors
-time: 2023-07-18T12:55:18.03914-04:00
-custom:
-  Author: michelleark
-  Issue: "8130"
--- a/.changes/unreleased/Fixes-20231013-130943.yaml
+++ b/.changes/unreleased/Fixes-20231013-130943.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: For packages installed with tarball method, fetch metadata to resolve nested dependencies
+time: 2023-10-13T13:09:43.188308-04:00
+custom:
+  Author: adamlopez
+  Issue: "8621"
--- a/.changes/unreleased/Fixes-20231016-163953.yaml
+++ b/.changes/unreleased/Fixes-20231016-163953.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Fix partial parsing not working for semantic model change
+time: 2023-10-16T16:39:53.05058-07:00
+custom:
+  Author: ChenyuLInx
+  Issue: "8859"
--- a/.changes/unreleased/Fixes-20231024-110151.yaml
+++ b/.changes/unreleased/Fixes-20231024-110151.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Handle unknown `type_code` for model contracts
+time: 2023-10-24T11:01:51.980781-06:00
+custom:
+  Author: dbeatty10
+  Issue: 8877 8353
--- a/.changes/unreleased/Fixes-20231024-145504.yaml
+++ b/.changes/unreleased/Fixes-20231024-145504.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Add back contract enforcement for temporary tables on postgres
+time: 2023-10-24T14:55:04.051683-05:00
+custom:
+  Author: emmyoop
+  Issue: "8857"
--- a/.changes/unreleased/Fixes-20231024-155400.yaml
+++ b/.changes/unreleased/Fixes-20231024-155400.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Rework get_catalog implementation to retain previous adapter interface semantics
+time: 2023-10-24T15:54:00.628086-04:00
+custom:
+  Author: peterallenwebb
+  Issue: "8846"
--- a/.changes/unreleased/Fixes-20231026-002536.yaml
+++ b/.changes/unreleased/Fixes-20231026-002536.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Add version to fqn when version==0
+time: 2023-10-26T00:25:36.259356-05:00
+custom:
+  Author: aranke
+  Issue: "8836"
--- a/.changes/unreleased/Fixes-20231030-093734.yaml
+++ b/.changes/unreleased/Fixes-20231030-093734.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Fix cased comparison in catalog-retrieval function.
+time: 2023-10-30T09:37:34.258612-04:00
+custom:
+  Author: peterallenwebb
+  Issue: "8939"
--- a/.changes/unreleased/Fixes-20231031-005345.yaml
+++ b/.changes/unreleased/Fixes-20231031-005345.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Catalog queries now assign the correct type to materialized views
+time: 2023-10-31T00:53:45.486203-04:00
+custom:
+  Author: mikealfare
+  Issue: "8864"
--- a/.changes/unreleased/Fixes-20231031-144837.yaml
+++ b/.changes/unreleased/Fixes-20231031-144837.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Fix compilation exception running empty seed file and support new Integer agate data_type
+time: 2023-10-31T14:48:37.774871-04:00
+custom:
+  Author: gshank
+  Issue: "8895"
--- a/.changes/unreleased/Fixes-20231101-155824.yaml
+++ b/.changes/unreleased/Fixes-20231101-155824.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Make relation filtering None-tolerant for maximal flexibility across adapters.
+time: 2023-11-01T15:58:24.552054-04:00
+custom:
+  Author: peterallenwebb
+  Issue: "8974"
--- a/.changes/unreleased/Fixes-20231106-155933.yaml
+++ b/.changes/unreleased/Fixes-20231106-155933.yaml
@@ -0,0 +1,7 @@
+kind: Fixes
+body: Update run_results.json from previous versions of dbt to support deferral and
+  rerun from failure
+time: 2023-11-06T15:59:33.677915-05:00
+custom:
+  Author: jtcohen6 peterallenwebb
+  Issue: "9010"
--- a/.changes/unreleased/Fixes-20231107-092358.yaml
+++ b/.changes/unreleased/Fixes-20231107-092358.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Fix git repository with subdirectory for Deps
+time: 2023-11-07T09:23:58.214271-08:00
+custom:
+  Author: ChenyuLInx
+  Issue: "9000"
--- a/.changes/unreleased/Fixes-20231107-094130.yaml
+++ b/.changes/unreleased/Fixes-20231107-094130.yaml
@@ -0,0 +1,7 @@
+kind: Fixes
+body: Use MANIFEST.in to recursively include all jinja templates; fixes issue where
+  some templates were not included in the distribution
+time: 2023-11-07T09:41:30.121733-05:00
+custom:
+  Author: mikealfare
+  Issue: "9016"
--- a/.changes/unreleased/Fixes-20231113-114956.yaml
+++ b/.changes/unreleased/Fixes-20231113-114956.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: Fix formatting of tarball information in packages-lock.yml
+time: 2023-11-13T11:49:56.437007-08:00
+custom:
+  Author: ChenyuLInx QMalcolm
+  Issue: "9062"
--- a/.changes/unreleased/Fixes-20231127-154310.yaml
+++ b/.changes/unreleased/Fixes-20231127-154310.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: 'deps: Lock git packages to commit SHA during resolution'
+time: 2023-11-27T15:43:10.122069+01:00
+custom:
+  Author: jtcohen6
+  Issue: "9050"
--- a/.changes/unreleased/Fixes-20231127-154347.yaml
+++ b/.changes/unreleased/Fixes-20231127-154347.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: 'deps: Use PackageRenderer to read package-lock.json'
+time: 2023-11-27T15:43:47.842423+01:00
+custom:
+  Author: jtcohen6
+  Issue: "9127"
--- a/.changes/unreleased/Fixes-20231127-165244.yaml
+++ b/.changes/unreleased/Fixes-20231127-165244.yaml
@@ -0,0 +1,7 @@
+kind: Fixes
+body: Ensure we produce valid jsonschema schemas for manifest, catalog, run-results,
+  and sources
+time: 2023-11-27T16:52:44.590313-08:00
+custom:
+  Author: QMalcolm
+  Issue: "8991"
--- a/.changes/unreleased/Fixes-20231128-155225.yaml
+++ b/.changes/unreleased/Fixes-20231128-155225.yaml
@@ -0,0 +1,6 @@
+kind: Fixes
+body: 'Get sources working again in dbt docs generate'
+time: 2023-11-28T15:52:25.738256Z
+custom:
+  Author: aranke
+  Issue: "9119"
--- a/Hood-20230831-164435.yaml
+++ b/Hood-20230831-164435.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Added more type annotations.
+time: 2023-08-31T16:44:35.737954-04:00
+custom:
+  Author: peterallenwebb
+  Issue: "8537"
--- a/Hood-20231026-184953.yaml
+++ b/Hood-20231026-184953.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Remove usage of dbt.include.global_project in dbt/adapters
+time: 2023-10-26T18:49:53.36449-04:00
+custom:
+  Author: michelleark
+  Issue: "8925"
--- a/Hood-20231027-140048.yaml
+++ b/Hood-20231027-140048.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Add a no-op runner for Saved Qeury
+time: 2023-10-27T14:00:48.4755-07:00
+custom:
+  Author: ChenyuLInx
+  Issue: "8893"
--- a/Hood-20231101-102758.yaml
+++ b/Hood-20231101-102758.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: remove dbt.flags.MP_CONTEXT usage in dbt/adapters
+time: 2023-11-01T10:27:58.790153-04:00
+custom:
+  Author: michelleark
+  Issue: "8967"
--- a/Hood-20231101-173124.yaml
+++ b/Hood-20231101-173124.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: 'Remove usage of dbt.flags.LOG_CACHE_EVENTS in dbt/adapters'
+time: 2023-11-01T17:31:24.974093-04:00
+custom:
+  Author: michelleark
+  Issue: "8969"
--- a/Hood-20231103-195222.yaml
+++ b/Hood-20231103-195222.yaml
@@ -0,0 +1,7 @@
+kind: Under the Hood
+body: Move CatalogRelationTypes test case to the shared test suite to be reused by
+  adapter maintainers
+time: 2023-11-03T19:52:22.694394-04:00
+custom:
+  Author: mikealfare
+  Issue: "8952"
--- a/Hood-20231106-080422.yaml
+++ b/Hood-20231106-080422.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Treat SystemExit as an interrupt if raised during node execution.
+time: 2023-11-06T08:04:22.022179-05:00
+custom:
+  Author: benmosher
+  Issue: n/a
--- a/Hood-20231106-105730.yaml
+++ b/Hood-20231106-105730.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Removing unused 'documentable'
+time: 2023-11-06T10:57:30.694056-08:00
+custom:
+  Author: QMalcolm
+  Issue: "8871"
--- a/Hood-20231107-135728.yaml
+++ b/Hood-20231107-135728.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Remove use of dbt/core exceptions in dbt/adapter
+time: 2023-11-07T13:57:28.683727-08:00
+custom:
+  Author: colin-rogers-dbt MichelleArk
+  Issue: "8920"
--- a/Hood-20231107-191546.yaml
+++ b/Hood-20231107-191546.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Cache dbt plugin modules to improve integration test performance
+time: 2023-11-07T19:15:46.170151-05:00
+custom:
+  Author: peterallenwebb
+  Issue: "9029"
--- a/Hood-20231111-175350.yaml
+++ b/Hood-20231111-175350.yaml
@@ -0,0 +1,7 @@
+kind: Under the Hood
+body: Fix test_current_timestamp_matches_utc test; allow for MacOS runner system clock
+  variance
+time: 2023-11-11T17:53:50.098843-05:00
+custom:
+  Author: mikealfare
+  Issue: "9057"
--- a/Hood-20231116-174251.yaml
+++ b/Hood-20231116-174251.yaml
@@ -0,0 +1,7 @@
+kind: Under the Hood
+body: Remove usage of dbt.deprecations in dbt/adapters, enable core & adapter-specific
+  event types and protos
+time: 2023-11-16T17:42:51.005023-05:00
+custom:
+  Author: michelleark
+  Issue: 8927 8918
--- a/Hood-20231120-134735.yaml
+++ b/Hood-20231120-134735.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Clean up unused adaptor folders
+time: 2023-11-20T13:47:35.923794-08:00
+custom:
+  Author: ChenyuLInx
+  Issue: "9123"
--- a/Hood-20231120-183214.yaml
+++ b/Hood-20231120-183214.yaml
@@ -0,0 +1,7 @@
+kind: Under the Hood
+body: Move column constraints into common/contracts, removing another dependency of
+  adapters on core.
+time: 2023-11-20T18:32:14.859503-05:00
+custom:
+  Author: peterallenwebb
+  Issue: "9024"
--- a/Hood-20231128-170732.yaml
+++ b/Hood-20231128-170732.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Move dbt.semver to dbt.common.semver and update references.
+time: 2023-11-28T17:07:32.172421-08:00
+custom:
+  Author: versusfacit
+  Issue: "9039"
--- a/Hood-20231130-135432.yaml
+++ b/Hood-20231130-135432.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Move lowercase utils method to common
+time: 2023-11-30T13:54:32.561673-08:00
+custom:
+  Author: colin-rogers-dbt
+  Issue: "9180"
--- a/Hood-20231205-093544.yaml
+++ b/Hood-20231205-093544.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Remove usages of dbt.clients.jinja in dbt/adapters
+time: 2023-12-05T09:35:44.845352+09:00
+custom:
+  Author: michelleark
+  Issue: "9205"
--- a/Hood-20231205-120559.yaml
+++ b/Hood-20231205-120559.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Remove usage of dbt.contracts in dbt/adapters
+time: 2023-12-05T12:05:59.936775+09:00
+custom:
+  Author: michelleark
+  Issue: "9208"
--- a/Hood-20231205-165812.yaml
+++ b/Hood-20231205-165812.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Remove usage of dbt.contracts.graph.nodes.ResultNode in dbt/adapters
+time: 2023-12-05T16:58:12.932172+09:00
+custom:
+  Author: michelleark
+  Issue: "9214"
--- a/Hood-20231205-170725.yaml
+++ b/Hood-20231205-170725.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Introduce RelationConfig Protocol, consolidate Relation.create_from
+time: 2023-12-05T17:07:25.33861+09:00
+custom:
+  Author: michelleark
+  Issue: "9215"
--- a/Hood-20231205-185022.yaml
+++ b/Hood-20231205-185022.yaml
@@ -0,0 +1,7 @@
+kind: Under the Hood
+body: Move BaseConfig, Metadata and various other contract classes from model_config
+  to common/contracts/config
+time: 2023-12-05T18:50:22.321229-08:00
+custom:
+  Author: colin-rorgers-dbt
+  Issue: "8919"
--- a/Hood-20231205-235830.yaml
+++ b/Hood-20231205-235830.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: remove manifest from adapter.set_relations_cache signature
+time: 2023-12-05T23:58:30.920144+09:00
+custom:
+  Author: michelleark
+  Issue: "9217"
--- a/Hood-20231206-000343.yaml
+++ b/Hood-20231206-000343.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: ' remove manifest from adapter catalog method signatures'
+time: 2023-12-06T00:03:43.824252+09:00
+custom:
+  Author: michelleark
+  Issue: "9218"
--- a/Hood-20231207-111554.yaml
+++ b/Hood-20231207-111554.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Add MacroResolverProtocol, remove lazy loading of manifest in adapter.execute_macro
+time: 2023-12-07T11:15:54.427818+09:00
+custom:
+  Author: michelleark
+  Issue: "9244"
--- a/Hood-20231208-004854.yaml
+++ b/Hood-20231208-004854.yaml
@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: add macro_context_generator on adapter
+time: 2023-12-08T00:48:54.506911+09:00
+custom:
+  Author: michelleark
+  Issue: "9247"
--- a/.flake8
+++ b/.flake8
@@ -10,3 +10,5 @@ ignore =
    E741
    E501 # long line checking is done in black
 exclude = test/
+per-file-ignores =
+    */__init__.py: F401
--- a/.gitattributes
+++ b/.gitattributes
@@ -1,4 +1,4 @@
-core/dbt/include/index.html binary
+core/dbt/task/docs/index.html binary
 tests/functional/artifacts/data/state/*/manifest.json binary
 core/dbt/docs/build/html/searchindex.js binary
 core/dbt/docs/build/html/index.html binary
--- a/.github/CODEOWNERS
+++ b/.github/CODEOWNERS
@@ -13,23 +13,6 @@
 # the core team as a whole will be assigned
 *       @dbt-labs/core-team

-### OSS Tooling Guild
-
-/.github/                       @dbt-labs/guild-oss-tooling
-.bumpversion.cfg                @dbt-labs/guild-oss-tooling
-
-.changie.yaml                   @dbt-labs/guild-oss-tooling
-
-pre-commit-config.yaml          @dbt-labs/guild-oss-tooling
-pytest.ini                      @dbt-labs/guild-oss-tooling
-tox.ini                         @dbt-labs/guild-oss-tooling
-
-pyproject.toml                  @dbt-labs/guild-oss-tooling
-requirements.txt                @dbt-labs/guild-oss-tooling
-dev_requirements.txt            @dbt-labs/guild-oss-tooling
-/core/setup.py                  @dbt-labs/guild-oss-tooling
-/core/MANIFEST.in               @dbt-labs/guild-oss-tooling
-
 ### ADAPTERS

 # Adapter interface ("base" + "sql" adapter defaults, cache)
@@ -40,7 +23,7 @@ dev_requirements.txt            @dbt-labs/guild-oss-tooling

 # Postgres plugin
 /plugins/                       @dbt-labs/core-adapters
-/plugins/postgres/setup.py      @dbt-labs/core-adapters @dbt-labs/guild-oss-tooling
+/plugins/postgres/setup.py      @dbt-labs/core-adapters

 # Functional tests for adapter plugins
 /tests/adapter                  @dbt-labs/core-adapters
--- a/.github/ISSUE_TEMPLATE/implementation-ticket.yml
+++ b/.github/ISSUE_TEMPLATE/implementation-ticket.yml
@@ -0,0 +1,58 @@
+name: 🛠️ Implementation
+description: This is an implementation ticket intended for use by the maintainers of dbt-core
+title: "[<project>] <title>"
+labels: ["user docs"]
+body:
+  - type: markdown
+    attributes:
+      value: This is an implementation ticket intended for use by the maintainers of dbt-core
+  - type: checkboxes
+    attributes:
+      label: Housekeeping
+      description: >
+        A couple friendly reminders:
+          1. Remove the `user docs` label if the scope of this work does not require changes to https://docs.getdbt.com/docs: no end-user interface (e.g. yml spec, CLI, error messages, etc) or functional changes
+          2. Link any blocking issues in the "Blocked on" field under the "Core devs & maintainers" project.
+      options:
+        - label: I am a maintainer of dbt-core
+          required: true
+  - type: textarea
+    attributes:
+      label: Short description
+      description: |
+        Describe the scope of the ticket, a high-level implementation approach and any tradeoffs to consider
+    validations:
+      required: true
+  - type: textarea
+    attributes:
+      label: Acceptance criteria
+      description: |
+        What is the definition of done for this ticket? Include any relevant edge cases and/or test cases
+    validations:
+      required: true
+  - type: textarea
+    attributes:
+      label: Impact to Other Teams
+      description: |
+        Will this change impact other teams?  Include details of the kinds of changes required (new tests, code changes, related tickets) and _add the relevant `Impact:[team]` label_.
+      placeholder: |
+        Example: This change impacts `dbt-redshift` because the tests will need to be modified.  The `Impact:[Adapter]` label has been added.
+    validations:
+      required: true
+  - type: textarea
+    attributes:
+      label: Will backports be required?
+      description: |
+        Will this change need to be backported to previous versions?  Add details, possible blockers to backporting and _add the relevant backport labels `backport 1.x.latest`_
+      placeholder: |
+        Example: Backport to 1.6.latest, 1.5.latest and 1.4.latest.  Since 1.4 isn't using click, the backport may be complicated. The `backport 1.6.latest`, `backport 1.5.latest` and `backport 1.4.latest` labels have been added.
+    validations:
+      required: true
+  - type: textarea
+    attributes:
+      label: Context
+      description: |
+        Provide the "why", motivation, and alternative approaches considered -- linking to previous refinement issues, spikes, Notion docs as appropriate
+          validations:
+    validations:
+      required: false
--- a/.github/dependabot.yml
+++ b/.github/dependabot.yml
@@ -28,3 +28,10 @@ updates:
    schedule:
      interval: "weekly"
    rebase-strategy: "disabled"
+
+  # github dependencies
+  - package-ecosystem: "github-actions"
+    directory: "/"
+    schedule:
+      interval: "weekly"
+    rebase-strategy: "disabled"
--- a/.github/pull_request_template.md
+++ b/.github/pull_request_template.md
@@ -1,15 +1,12 @@
-resolves #  
-[docs](https://github.com/dbt-labs/docs.getdbt.com/issues/new/choose) dbt-labs/docs.getdbt.com/#  
+resolves #

 <!---
  Include the number of the issue addressed by this PR above if applicable.
  PRs for code changes without an associated issue *will not be merged*.
  See CONTRIBUTING.md for more information.

-  Include the number of the docs issue that was opened for this PR. If
-  this change has no user-facing implications, "N/A" suffices instead. New
-  docs tickets can be created by clicking the link above or by going to
-  https://github.com/dbt-labs/docs.getdbt.com/issues/new/choose.
+  Add the `user docs` label to this PR if it will need docs changes.  An 
+  issue will get opened in docs.getdbt.com upon successful merge of this PR.
 -->

 ### Problem
@@ -33,3 +30,4 @@ resolves #
 - [ ] I have run this code in development and it appears to resolve the stated issue  
 - [ ] This PR includes tests, or tests are not required/relevant for this PR
 - [ ] This PR has no interface changes (e.g. macros, cli, logs, json artifacts, config files, adapter interface, etc) or this PR has already received feedback and approval from Product or DX
+- [ ] This PR includes [type annotations](https://docs.python.org/3/library/typing.html) for new and modified functions
--- a/.github/workflows/changelog-existence.yml
+++ b/.github/workflows/changelog-existence.yml
@@ -2,10 +2,8 @@
 # Checks that a file has been committed under the /.changes directory
 # as a new CHANGELOG entry.  Cannot check for a specific filename as
 # it is dynamically generated by change type and timestamp.
-# This workflow should not require any secrets since it runs for PRs
-# from forked repos.
-# By default, secrets are not passed to workflows running from
-# a forked repo.
+# This workflow runs on pull_request_target because it requires
+# secrets to post comments.

 # **why?**
 # Ensure code change gets reflected in the CHANGELOG.
@@ -19,7 +17,7 @@
 name: Check Changelog Entry

 on:
-  pull_request:
+  pull_request_target:
    types: [opened, reopened, labeled, unlabeled, synchronize]
  workflow_dispatch:

--- a/.github/workflows/docs-issue.yml
+++ b/.github/workflows/docs-issue.yml
@@ -0,0 +1,43 @@
+# **what?**
+# Open an issue in docs.getdbt.com when a PR is labeled `user docs`
+
+# **why?**
+# To reduce barriers for keeping docs up to date
+
+# **when?**
+# When a PR is labeled `user docs` and is merged.  Runs on pull_request_target to run off the workflow already merged,
+# not the workflow that existed on the PR branch.  This allows old PRs to get comments.
+
+
+name: Open issues in docs.getdbt.com repo when a PR is labeled
+run-name: "Open an issue in docs.getdbt.com for PR #${{ github.event.pull_request.number }}"
+
+on:
+  pull_request_target:
+    types: [labeled, closed]
+
+defaults:
+  run:
+    shell: bash
+
+permissions:
+    issues: write # opens new issues
+    pull-requests: write # comments on PRs
+
+
+jobs:
+  open_issues:
+    # we only want to run this when the PR has been merged or the label in the labeled event is `user docs`.  Otherwise it runs the
+    # risk of duplicaton of issues being created due to merge and label both triggering this workflow to run and neither having
+    # generating the comment before the other runs.  This lives here instead of the shared workflow because this is where we
+    # decide if it should run or not.
+    if: |
+      (github.event.pull_request.merged == true) &&
+      ((github.event.action == 'closed' && contains( github.event.pull_request.labels.*.name, 'user docs')) ||
+      (github.event.action == 'labeled' && github.event.label.name == 'user docs'))
+    uses: dbt-labs/actions/.github/workflows/open-issue-in-repo.yml@main
+    with:
+        issue_repository: "dbt-labs/docs.getdbt.com"
+        issue_title: "Docs Changes Needed from ${{ github.event.repository.name }} PR #${{ github.event.pull_request.number }}"
+        issue_body: "At a minimum, update body to include a link to the page on docs.getdbt.com requiring updates and what part(s) of the page you would like to see updated."
+    secrets: inherit
--- a/.github/workflows/main.yml
+++ b/.github/workflows/main.yml
@@ -33,6 +33,11 @@ defaults:
  run:
    shell: bash

+# top-level adjustments can be made here
+env:
+  # number of parallel processes to spawn for python integration testing
+  PYTHON_INTEGRATION_TEST_WORKERS: 5
+
 jobs:
  code-quality:
    name: code-quality
@@ -103,26 +108,59 @@ jobs:
      - name: Upload Unit Test Coverage to Codecov
        if: ${{ matrix.python-version == '3.11' }}
        uses: codecov/codecov-action@v3
-        env:
-          CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
+        with:
+          token: ${{ secrets.CODECOV_TOKEN }}
+          flags: unit
+
+  integration-metadata:
+    name: integration test metadata generation
+    runs-on: ubuntu-latest
+    outputs:
+      split-groups: ${{ steps.generate-split-groups.outputs.split-groups }}
+      include: ${{ steps.generate-include.outputs.include }}
+
+    steps:
+      - name: generate split-groups
+        id: generate-split-groups
+        run: |
+          MATRIX_JSON="["
+          for B in $(seq 1 ${{ env.PYTHON_INTEGRATION_TEST_WORKERS }}); do
+              MATRIX_JSON+=$(sed 's/^/"/;s/$/"/' <<< "${B}")
+          done
+          MATRIX_JSON="${MATRIX_JSON//\"\"/\", \"}"
+          MATRIX_JSON+="]"
+          echo "split-groups=${MATRIX_JSON}"
+          echo "split-groups=${MATRIX_JSON}" >> $GITHUB_OUTPUT
+
+      - name: generate include
+        id: generate-include
+        run: |
+          INCLUDE=('"python-version":"3.8","os":"windows-latest"' '"python-version":"3.8","os":"macos-latest"' )
+          INCLUDE_GROUPS="["
+          for include in ${INCLUDE[@]}; do
+              for group in $(seq 1 ${{ env.PYTHON_INTEGRATION_TEST_WORKERS }}); do
+                  INCLUDE_GROUPS+=$(sed 's/$/, /' <<< "{\"split-group\":\"${group}\",${include}}")
+              done
+          done
+          INCLUDE_GROUPS=$(echo $INCLUDE_GROUPS | sed 's/,*$//g')
+          INCLUDE_GROUPS+="]"
+          echo "include=${INCLUDE_GROUPS}"
+          echo "include=${INCLUDE_GROUPS}" >> $GITHUB_OUTPUT

  integration:
-    name: integration test / python ${{ matrix.python-version }} / ${{ matrix.os }}
+    name: (${{ matrix.split-group }}) integration test / python ${{ matrix.python-version }} / ${{ matrix.os }}

    runs-on: ${{ matrix.os }}
-    timeout-minutes: 60
-
+    timeout-minutes: 30
+    needs:
+      - integration-metadata
    strategy:
      fail-fast: false
      matrix:
        python-version: ["3.8", "3.9", "3.10", "3.11"]
        os: [ubuntu-20.04]
-        include:
-          - python-version: 3.8
-            os: windows-latest
-          - python-version: 3.8
-            os: macos-latest
-
+        split-group: ${{ fromJson(needs.integration-metadata.outputs.split-groups) }}
+        include: ${{ fromJson(needs.integration-metadata.outputs.include) }}
    env:
      TOXENV: integration
      DBT_INVOCATION_ENV: github-actions
@@ -165,6 +203,8 @@ jobs:

      - name: Run tests
        run: tox -- --ddtrace
+        env:
+          PYTEST_ADDOPTS: ${{ format('--splits {0} --group {1}', env.PYTHON_INTEGRATION_TEST_WORKERS, matrix.split-group) }}

      - name: Get current date
        if: always()
@@ -182,8 +222,26 @@ jobs:
      - name: Upload Integration Test Coverage to Codecov
        if: ${{ matrix.python-version == '3.11' }}
        uses: codecov/codecov-action@v3
-        env:
-          CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
+        with:
+          token: ${{ secrets.CODECOV_TOKEN }}
+          flags: integration
+
+  integration-report:
+    if: ${{ always() }}
+    name: Integration Test Suite
+    runs-on: ubuntu-latest
+    needs: integration
+    steps:
+      - name: "Integration Tests Failed"
+        if: ${{ contains(needs.integration.result, 'failure') || contains(needs.integration.result, 'cancelled') }}
+        # when this is true the next step won't execute
+        run: |
+          echo "::notice title='Integration test suite failed'"
+          exit 1
+
+      - name: "Integration Tests Passed"
+        run: |
+          echo "::notice title='Integration test suite passed'"

  build:
    name: build packages
--- a/.github/workflows/release-docker.yml
+++ b/.github/workflows/release-docker.yml
@@ -83,7 +83,7 @@ jobs:
          password: ${{ secrets.GITHUB_TOKEN }}

      - name: Build and push MAJOR.MINOR.PATCH tag
-        uses: docker/build-push-action@v4
+        uses: docker/build-push-action@v5
        with:
          file: docker/Dockerfile
          push: True
@@ -94,7 +94,7 @@ jobs:
            ghcr.io/dbt-labs/${{ github.event.inputs.package }}:${{ github.event.inputs.version_number }}

      - name: Build and push MINOR.latest tag
-        uses: docker/build-push-action@v4
+        uses: docker/build-push-action@v5
        if: ${{ needs.get_version_meta.outputs.minor_latest == 'True' }}
        with:
          file: docker/Dockerfile
@@ -106,7 +106,7 @@ jobs:
            ghcr.io/dbt-labs/${{ github.event.inputs.package }}:${{ needs.get_version_meta.outputs.major }}.${{ needs.get_version_meta.outputs.minor }}.latest

      - name: Build and push latest tag
-        uses: docker/build-push-action@v4
+        uses: docker/build-push-action@v5
        if: ${{ needs.get_version_meta.outputs.latest == 'True' }}
        with:
          file: docker/Dockerfile
--- a/.github/workflows/repository-cleanup.yml
+++ b/.github/workflows/repository-cleanup.yml
@@ -0,0 +1,30 @@
+# **what?**
+# Cleanup branches left over from automation and testing.  Also cleanup
+# draft releases from release testing.
+
+# **why?**
+# The automations are leaving behind branches and releases that clutter
+# the repository.  Sometimes we need them to debug processes so we don't
+# want them immediately deleted.  Running on Saturday to avoid running
+# at the same time as an actual release to prevent breaking a release
+# mid-release.
+
+# **when?**
+# Mainly on a schedule of 12:00 Saturday.
+# Manual trigger can also run on demand
+
+name: Repository Cleanup
+
+on:
+  schedule:
+    - cron: '0 12 * * SAT' # At 12:00 on Saturday - details in `why` above
+
+  workflow_dispatch: # for manual triggering
+
+permissions:
+  contents: write
+
+jobs:
+  cleanup-repo:
+    uses: dbt-labs/actions/.github/workflows/repository-cleanup.yml@main
+    secrets: inherit
--- a/.github/workflows/structured-logging-schema-check.yml
+++ b/.github/workflows/structured-logging-schema-check.yml
@@ -18,11 +18,41 @@ on:

 permissions: read-all

+# top-level adjustments can be made here
+env:
+  # number of parallel processes to spawn for python testing
+  PYTHON_INTEGRATION_TEST_WORKERS: 5
+
 jobs:
+  integration-metadata:
+    name: integration test metadata generation
+    runs-on: ubuntu-latest
+    outputs:
+      split-groups: ${{ steps.generate-split-groups.outputs.split-groups }}
+
+    steps:
+      - name: generate split-groups
+        id: generate-split-groups
+        run: |
+          MATRIX_JSON="["
+          for B in $(seq 1 ${{ env.PYTHON_INTEGRATION_TEST_WORKERS }}); do
+              MATRIX_JSON+=$(sed 's/^/"/;s/$/"/' <<< "${B}")
+          done
+          MATRIX_JSON="${MATRIX_JSON//\"\"/\", \"}"
+          MATRIX_JSON+="]"
+          echo "split-groups=${MATRIX_JSON}" >> $GITHUB_OUTPUT
+
  # run the performance measurements on the current or default branch
  test-schema:
    name: Test Log Schema
    runs-on: ubuntu-20.04
+    timeout-minutes: 30
+    needs:
+      - integration-metadata
+    strategy:
+      fail-fast: false
+      matrix:
+        split-group: ${{ fromJson(needs.integration-metadata.outputs.split-groups) }}
    env:
      # turns warnings into errors
      RUSTFLAGS: "-D warnings"
@@ -65,3 +95,14 @@ jobs:
      # we actually care if these pass, because the normal test run doesn't usually include many json log outputs
      - name: Run integration tests
        run: tox -e integration -- -nauto
+        env:
+          PYTEST_ADDOPTS: ${{ format('--splits {0} --group {1}', env.PYTHON_INTEGRATION_TEST_WORKERS, matrix.split-group) }}
+
+  test-schema-report:
+    name: Log Schema Test Suite
+    runs-on: ubuntu-latest
+    needs: test-schema
+    steps:
+      - name: "[Notification] Log test suite passes"
+        run: |
+          echo "::notice title="Log test suite passes""
--- a/.pre-commit-config.yaml
+++ b/.pre-commit-config.yaml
@@ -1,7 +1,7 @@
 # Configuration for pre-commit hooks (see https://pre-commit.com/).
 # Eventually the hooks described here will be run as tests before merging each PR.

-exclude: ^(core/dbt/docs/build/|core/dbt/events/types_pb2.py)
+exclude: ^(core/dbt/docs/build/|core/dbt/common/events/types_pb2.py|core/dbt/events/core_types_pb2.py|core/dbt/adapters/events/adapter_types_pb2.py)

 # Force all unspecified python hooks to run python 3.8
 default_language_version:
@@ -37,7 +37,7 @@ repos:
    alias: flake8-check
    stages: [manual]
 - repo: https://github.com/pre-commit/mirrors-mypy
-  rev: v1.3.0
+  rev: v1.4.1
  hooks:
  - id: mypy
    # N.B.: Mypy is... a bit fragile.
--- a/ARCHITECTURE.md
+++ b/ARCHITECTURE.md
@@ -26,7 +26,7 @@ Legacy tests are found in the 'test' directory:

 The "tasks" map to top-level dbt commands. So `dbt run` => task.run.RunTask, etc. Some are more like abstract base classes (GraphRunnableTask, for example) but all the concrete types outside of task should map to tasks. Currently one executes at a time. The tasks kick off their “Runners” and those do execute in parallel. The parallelism is managed via a thread pool, in GraphRunnableTask.

-core/dbt/include/index.html
+core/dbt/task/docs/index.html
 This is the docs website code. It comes from the dbt-docs repository, and is generated when a release is packaged.

 ## Adapters
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -10,6 +10,7 @@
 For information on prior major and minor releases, see their changelogs:


+* [1.7](https://github.com/dbt-labs/dbt-core/blob/1.7.latest/CHANGELOG.md)
 * [1.6](https://github.com/dbt-labs/dbt-core/blob/1.6.latest/CHANGELOG.md)
 * [1.5](https://github.com/dbt-labs/dbt-core/blob/1.5.latest/CHANGELOG.md)
 * [1.4](https://github.com/dbt-labs/dbt-core/blob/1.4.latest/CHANGELOG.md)
--- a/11
+++ b/11
@@ -40,7 +40,16 @@ dev: dev_req ## Installs dbt-* packages in develop mode along with development d

 .PHONY: proto_types
 proto_types:  ## generates google protobuf python file from types.proto
-	protoc -I=./core/dbt/events --python_out=./core/dbt/events ./core/dbt/events/types.proto
+	protoc -I=./core/dbt/common/events --python_out=./core/dbt/common/events ./core/dbt/common/events/types.proto
+
+.PHONY: core_proto_types
+core_proto_types:  ## generates google protobuf python file from core_types.proto
+	protoc -I=./core/dbt/events --python_out=./core/dbt/events ./core/dbt/events/core_types.proto
+
+.PHONY: adapter_proto_types
+adapter_proto_types:  ## generates google protobuf python file from core_types.proto
+	protoc -I=./core/dbt/adapters/events --python_out=./core/dbt/adapters/events ./core/dbt/adapters/events/adapter_types.proto
+

 .PHONY: mypy
 mypy: .env ## Runs mypy against staged changes for static type checking.
--- a/codecov.yml
+++ b/codecov.yml
@@ -0,0 +1,13 @@
+ignore:
+  - ".github"
+  - ".changes"
+coverage:
+  status:
+    project:
+      default:
+        target: auto
+        threshold: 0.1% # Reduce noise by ignoring rounding errors in coverage drops
+    patch:
+      default:
+        target: auto
+        threshold: 80%
--- a/core/dbt/adapters/base/init.py
+++ b/core/dbt/adapters/base/init.py
@@ -1,7 +1,7 @@
 # these are all just exports, #noqa them so flake8 will be happy

 # TODO: Should we still include this in the `adapters` namespace?
-from dbt.contracts.connection import Credentials  # noqa: F401
+from dbt.adapters.contracts.connection import Credentials  # noqa: F401
 from dbt.adapters.base.meta import available  # noqa: F401
 from dbt.adapters.base.connections import BaseConnectionManager  # noqa: F401
 from dbt.adapters.base.relation import (  # noqa: F401
--- a/core/dbt/adapters/base/column.py
+++ b/core/dbt/adapters/base/column.py
@@ -2,17 +2,17 @@ from dataclasses import dataclass
 import re
 from typing import Dict, ClassVar, Any, Optional

-from dbt.exceptions import DbtRuntimeError
+from dbt.common.exceptions import DbtRuntimeError


@dataclass
 class Column:
+    # Note: This is automatically used by contract code
+    # No-op conversions (INTEGER => INT) have been removed.
+    # Any adapter that wants to take advantage of "translate_type"
+    # should create a ClassVar with the appropriate conversions.
    TYPE_LABELS: ClassVar[Dict[str, str]] = {
        "STRING": "TEXT",
-        "TIMESTAMP": "TIMESTAMP",
-        "FLOAT": "FLOAT",
-        "INTEGER": "INT",
-        "BOOLEAN": "BOOLEAN",
    }
    column: str
    dtype: str
--- a/core/dbt/adapters/base/connections.py
+++ b/core/dbt/adapters/base/connections.py
@@ -6,6 +6,7 @@ import traceback

 # multiprocessing.RLock is a function returning this type
 from multiprocessing.synchronize import RLock
+from multiprocessing.context import SpawnContext
 from threading import get_ident
 from typing import (
    Any,
@@ -23,8 +24,9 @@ from typing import (

 import agate

-import dbt.exceptions
-from dbt.contracts.connection import (
+import dbt.adapters.exceptions
+import dbt.common.exceptions.base
+from dbt.adapters.contracts.connection import (
    Connection,
    Identifier,
    ConnectionState,
@@ -36,9 +38,9 @@ from dbt.contracts.graph.manifest import Manifest
 from dbt.adapters.base.query_headers import (
    MacroQueryStringSetter,
 )
-from dbt.events import AdapterLogger
-from dbt.events.functions import fire_event
-from dbt.events.types import (
+from dbt.adapters.events.logging import AdapterLogger
+from dbt.common.events.functions import fire_event
+from dbt.adapters.events.types import (
    NewConnection,
    ConnectionReused,
    ConnectionLeftOpenInCleanup,
@@ -48,9 +50,8 @@ from dbt.events.types import (
    Rollback,
    RollbackFailed,
 )
-from dbt.events.contextvars import get_node_info
-from dbt import flags
-from dbt.utils import cast_to_str
+from dbt.common.events.contextvars import get_node_info
+from dbt.common.utils import cast_to_str

 SleepTime = Union[int, float]  # As taken by time.sleep.
 AdapterHandle = Any  # Adapter connection handle objects can be any class.
@@ -72,10 +73,10 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):

    TYPE: str = NotImplemented

-    def __init__(self, profile: AdapterRequiredConfig):
+    def __init__(self, profile: AdapterRequiredConfig, mp_context: SpawnContext) -> None:
        self.profile = profile
        self.thread_connections: Dict[Hashable, Connection] = {}
-        self.lock: RLock = flags.MP_CONTEXT.RLock()
+        self.lock: RLock = mp_context.RLock()
        self.query_header: Optional[MacroQueryStringSetter] = None

    def set_query_header(self, manifest: Manifest) -> None:
@@ -91,13 +92,15 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
        key = self.get_thread_identifier()
        with self.lock:
            if key not in self.thread_connections:
-                raise dbt.exceptions.InvalidConnectionError(key, list(self.thread_connections))
+                raise dbt.adapters.exceptions.InvalidConnectionError(
+                    key, list(self.thread_connections)
+                )
            return self.thread_connections[key]

    def set_thread_connection(self, conn: Connection) -> None:
        key = self.get_thread_identifier()
        if key in self.thread_connections:
-            raise dbt.exceptions.DbtInternalError(
+            raise dbt.common.exceptions.DbtInternalError(
                "In set_thread_connection, existing connection exists for {}"
            )
        self.thread_connections[key] = conn
@@ -137,13 +140,13 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
        :return: A context manager that handles exceptions raised by the
            underlying database.
        """
-        raise dbt.exceptions.NotImplementedError(
+        raise dbt.common.exceptions.base.NotImplementedError(
            "`exception_handler` is not implemented for this adapter!"
        )

    def set_connection_name(self, name: Optional[str] = None) -> Connection:
        """Called by 'acquire_connection' in BaseAdapter, which is called by
-        'connection_named', called by 'connection_for(node)'.
+        'connection_named'.
        Creates a connection for this thread if one doesn't already
        exist, and will rename an existing connection."""

@@ -220,14 +223,14 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
        :param int _attempts: Parameter used to keep track of the number of attempts in calling the
            connect function across recursive calls. Passed as an argument to retry_timeout if it
            is a Callable. This parameter should not be set by the initial caller.
-        :raises dbt.exceptions.FailedToConnectError: Upon exhausting all retry attempts without
+        :raises dbt.adapters.exceptions.FailedToConnectError: Upon exhausting all retry attempts without
            successfully acquiring a handle.
        :return: The given connection with its appropriate state and handle attributes set
            depending on whether we successfully acquired a handle or not.
        """
        timeout = retry_timeout(_attempts) if callable(retry_timeout) else retry_timeout
        if timeout < 0:
-            raise dbt.exceptions.FailedToConnectError(
+            raise dbt.adapters.exceptions.FailedToConnectError(
                "retry_timeout cannot be negative or return a negative time."
            )

@@ -235,7 +238,7 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
            # This guard is not perfect others may add to the recursion limit (e.g. built-ins).
            connection.handle = None
            connection.state = ConnectionState.FAIL
-            raise dbt.exceptions.FailedToConnectError("retry_limit cannot be negative")
+            raise dbt.adapters.exceptions.FailedToConnectError("retry_limit cannot be negative")

        try:
            connection.handle = connect()
@@ -246,7 +249,7 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
            if retry_limit <= 0:
                connection.handle = None
                connection.state = ConnectionState.FAIL
-                raise dbt.exceptions.FailedToConnectError(str(e))
+                raise dbt.adapters.exceptions.FailedToConnectError(str(e))

            logger.debug(
                f"Got a retryable error when attempting to open a {cls.TYPE} connection.\n"
@@ -268,12 +271,12 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
        except Exception as e:
            connection.handle = None
            connection.state = ConnectionState.FAIL
-            raise dbt.exceptions.FailedToConnectError(str(e))
+            raise dbt.adapters.exceptions.FailedToConnectError(str(e))

    @abc.abstractmethod
    def cancel_open(self) -> Optional[List[str]]:
        """Cancel all open connections on the adapter. (passable)"""
-        raise dbt.exceptions.NotImplementedError(
+        raise dbt.common.exceptions.base.NotImplementedError(
            "`cancel_open` is not implemented for this adapter!"
        )

@@ -288,7 +291,9 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
        This should be thread-safe, or hold the lock if necessary. The given
        connection should not be in either in_use or available.
        """
-        raise dbt.exceptions.NotImplementedError("`open` is not implemented for this adapter!")
+        raise dbt.common.exceptions.base.NotImplementedError(
+            "`open` is not implemented for this adapter!"
+        )

    def release(self) -> None:
        with self.lock:
@@ -320,12 +325,16 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
    @abc.abstractmethod
    def begin(self) -> None:
        """Begin a transaction. (passable)"""
-        raise dbt.exceptions.NotImplementedError("`begin` is not implemented for this adapter!")
+        raise dbt.common.exceptions.base.NotImplementedError(
+            "`begin` is not implemented for this adapter!"
+        )

    @abc.abstractmethod
    def commit(self) -> None:
        """Commit a transaction. (passable)"""
-        raise dbt.exceptions.NotImplementedError("`commit` is not implemented for this adapter!")
+        raise dbt.common.exceptions.base.NotImplementedError(
+            "`commit` is not implemented for this adapter!"
+        )

    @classmethod
    def _rollback_handle(cls, connection: Connection) -> None:
@@ -361,7 +370,7 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
    def _rollback(cls, connection: Connection) -> None:
        """Roll back the given connection."""
        if connection.transaction_open is False:
-            raise dbt.exceptions.DbtInternalError(
+            raise dbt.common.exceptions.DbtInternalError(
                f"Tried to rollback transaction on connection "
                f'"{connection.name}", but it does not have one open!'
            )
@@ -400,7 +409,7 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):

    @abc.abstractmethod
    def execute(
-        self, sql: str, auto_begin: bool = False, fetch: bool = False
+        self, sql: str, auto_begin: bool = False, fetch: bool = False, limit: Optional[int] = None
    ) -> Tuple[AdapterResponse, agate.Table]:
        """Execute the given SQL.

@@ -408,7 +417,30 @@ class BaseConnectionManager(metaclass=abc.ABCMeta):
        :param bool auto_begin: If set, and dbt is not currently inside a
            transaction, automatically begin one.
        :param bool fetch: If set, fetch results.
+        :param int limit: If set, limits the result set
        :return: A tuple of the query status and results (empty if fetch=False).
        :rtype: Tuple[AdapterResponse, agate.Table]
        """
-        raise dbt.exceptions.NotImplementedError("`execute` is not implemented for this adapter!")
+        raise dbt.common.exceptions.base.NotImplementedError(
+            "`execute` is not implemented for this adapter!"
+        )
+
+    def add_select_query(self, sql: str) -> Tuple[Connection, Any]:
+        """
+        This was added here because base.impl.BaseAdapter.get_column_schema_from_query expects it to be here.
+        That method wouldn't work unless the adapter used sql.impl.SQLAdapter, sql.connections.SQLConnectionManager
+        or defined this method on <Adapter>ConnectionManager before passing it in to <Adapter>Adapter.
+
+        See https://github.com/dbt-labs/dbt-core/issues/8396 for more information.
+        """
+        raise dbt.common.exceptions.base.NotImplementedError(
+            "`add_select_query` is not implemented for this adapter!"
+        )
+
+    @classmethod
+    def data_type_code_to_name(cls, type_code: Union[int, str]) -> str:
+        """Get the string representation of the data type from the type_code."""
+        # https://peps.python.org/pep-0249/#type-objects
+        raise dbt.common.exceptions.base.NotImplementedError(
+            "`data_type_code_to_name` is not implemented for this adapter!"
+        )
--- a/core/dbt/adapters/base/impl.py
+++ b/core/dbt/adapters/base/impl.py
@@ -4,12 +4,10 @@ from contextlib import contextmanager
 from datetime import datetime
 from enum import Enum
 import time
-from itertools import chain
 from typing import (
    Any,
    Callable,
    Dict,
-    Iterable,
    Iterator,
    List,
    Mapping,
@@ -17,39 +15,56 @@ from typing import (
    Set,
    Tuple,
    Type,
+    TypedDict,
    Union,
+    FrozenSet,
+    Iterable,
 )
+from multiprocessing.context import SpawnContext

-from dbt.contracts.graph.nodes import ColumnLevelConstraint, ConstraintType, ModelLevelConstraint
+from dbt.adapters.capability import Capability, CapabilityDict
+from dbt.common.contracts.constraints import (
+    ColumnLevelConstraint,
+    ConstraintType,
+    ModelLevelConstraint,
+)
+from dbt.adapters.contracts.macros import MacroClient

 import agate
 import pytz

-from dbt.exceptions import (
+from dbt.adapters.exceptions import (
+    SnapshotTargetIncompleteError,
+    SnapshotTargetNotSnapshotTableError,
+    NullRelationDropAttemptedError,
+    NullRelationCacheAttemptedError,
+    RelationReturnedMultipleResultsError,
+    UnexpectedNonTimestampError,
+    RenameToNoneAttemptedError,
+    QuoteConfigTypeError,
+)
+
+from dbt.common.exceptions import (
+    NotImplementedError,
    DbtInternalError,
    DbtRuntimeError,
    DbtValidationError,
+    UnexpectedNullError,
    MacroArgTypeError,
    MacroResultError,
-    NotImplementedError,
-    NullRelationCacheAttemptedError,
-    NullRelationDropAttemptedError,
-    QuoteConfigTypeError,
-    RelationReturnedMultipleResultsError,
-    RenameToNoneAttemptedError,
-    SnapshotTargetIncompleteError,
-    SnapshotTargetNotSnapshotTableError,
-    UnexpectedNonTimestampError,
-    UnexpectedNullError,
 )

-from dbt.adapters.protocol import AdapterConfig, ConnectionManagerProtocol
-from dbt.clients.agate_helper import empty_table, merge_tables, table_from_rows
-from dbt.clients.jinja import MacroGenerator
-from dbt.contracts.graph.manifest import Manifest, MacroManifest
-from dbt.contracts.graph.nodes import ResultNode
-from dbt.events.functions import fire_event, warn_or_error
-from dbt.events.types import (
+from dbt.adapters.protocol import AdapterConfig
+from dbt.common.clients.agate_helper import (
+    empty_table,
+    get_column_value_uncased,
+    merge_tables,
+    table_from_rows,
+    Integer,
+)
+from dbt.common.clients.jinja import CallableMacroGenerator
+from dbt.common.events.functions import fire_event, warn_or_error
+from dbt.adapters.events.types import (
    CacheMiss,
    ListRelations,
    CodeExecution,
@@ -58,9 +73,14 @@ from dbt.events.types import (
    ConstraintNotSupported,
    ConstraintNotEnforced,
 )
-from dbt.utils import filter_null_values, executor, cast_to_str, AttrDict
+from dbt.common.utils import filter_null_values, executor, cast_to_str, AttrDict

-from dbt.adapters.base.connections import Connection, AdapterResponse
+from dbt.adapters.contracts.relation import RelationConfig
+from dbt.adapters.base.connections import (
+    Connection,
+    AdapterResponse,
+    BaseConnectionManager,
+)
 from dbt.adapters.base.meta import AdapterMeta, available
 from dbt.adapters.base.relation import (
    ComponentName,
@@ -71,10 +91,13 @@ from dbt.adapters.base.relation import (
 from dbt.adapters.base import Column as BaseColumn
 from dbt.adapters.base import Credentials
 from dbt.adapters.cache import RelationsCache, _make_ref_key_dict
-from dbt import deprecations
+from dbt.adapters.events.types import CollectFreshnessReturnSignature
+

 GET_CATALOG_MACRO_NAME = "get_catalog"
+GET_CATALOG_RELATIONS_MACRO_NAME = "get_catalog_relations"
 FRESHNESS_MACRO_NAME = "collect_freshness"
+GET_RELATION_LAST_MODIFIED_MACRO_NAME = "get_relation_last_modified"


 class ConstraintSupport(str, Enum):
@@ -91,11 +114,13 @@ def _expect_row_value(key: str, row: agate.Row):
    return row[key]


-def _catalog_filter_schemas(manifest: Manifest) -> Callable[[agate.Row], bool]:
+def _catalog_filter_schemas(
+    used_schemas: FrozenSet[Tuple[str, str]]
+) -> Callable[[agate.Row], bool]:
    """Return a function that takes a row and decides if the row should be
    included in the catalog output.
    """
-    schemas = frozenset((d.lower(), s.lower()) for d, s in manifest.get_used_schemas())
+    schemas = frozenset((d.lower(), s.lower()) for d, s in used_schemas)

    def test(row: agate.Row) -> bool:
        table_database = _expect_row_value("table_database", row)
@@ -109,7 +134,7 @@ def _catalog_filter_schemas(manifest: Manifest) -> Callable[[agate.Row], bool]:
    return test


-def _utc(dt: Optional[datetime], source: BaseRelation, field_name: str) -> datetime:
+def _utc(dt: Optional[datetime], source: Optional[BaseRelation], field_name: str) -> datetime:
    """If dt has a timezone, return a new datetime that's in UTC. Otherwise,
    assume the datetime is already for UTC and add the timezone.
    """
@@ -161,6 +186,12 @@ class PythonJobHelper:
        raise NotImplementedError("PythonJobHelper submit function is not implemented yet")


+class FreshnessResponse(TypedDict):
+    max_loaded_at: datetime
+    snapshotted_at: datetime
+    age: float  # age in seconds
+
+
 class BaseAdapter(metaclass=AdapterMeta):
    """The BaseAdapter provides an abstract base class for adapters.

@@ -208,7 +239,7 @@ class BaseAdapter(metaclass=AdapterMeta):

    Relation: Type[BaseRelation] = BaseRelation
    Column: Type[BaseColumn] = BaseColumn
-    ConnectionManager: Type[ConnectionManagerProtocol]
+    ConnectionManager: Type[BaseConnectionManager]

    # A set of clobber config fields accepted by this adapter
    # for use in materializations
@@ -222,11 +253,28 @@ class BaseAdapter(metaclass=AdapterMeta):
        ConstraintType.foreign_key: ConstraintSupport.ENFORCED,
    }

-    def __init__(self, config):
+    # This static member variable can be overriden in concrete adapter
+    # implementations to indicate adapter support for optional capabilities.
+    _capabilities = CapabilityDict({})
+
+    def __init__(self, config, mp_context: SpawnContext) -> None:
        self.config = config
-        self.cache = RelationsCache()
-        self.connections = self.ConnectionManager(config)
-        self._macro_manifest_lazy: Optional[MacroManifest] = None
+        self.cache = RelationsCache(log_cache_events=config.log_cache_events)
+        self.connections = self.ConnectionManager(config, mp_context)
+        self._macro_client: Optional[MacroClient] = None
+
+    ###
+    # Methods to set / access a macro client
+    ###
+    def set_macro_client(self, macro_client: MacroClient) -> None:
+        self._macro_client = macro_client
+
+    def get_macro_client(self) -> Optional[MacroClient]:
+        return self._macro_client
+
+    def clear_macro_client(self) -> None:
+        if self._macro_client is not None:
+            self._macro_client = None

    ###
    # Methods that pass through to the connection manager
@@ -256,10 +304,10 @@ class BaseAdapter(metaclass=AdapterMeta):
        return conn.name

    @contextmanager
-    def connection_named(self, name: str, node: Optional[ResultNode] = None) -> Iterator[None]:
+    def connection_named(self, name: str, query_header_context: Any = None) -> Iterator[None]:
        try:
            if self.connections.query_header is not None:
-                self.connections.query_header.set(name, node)
+                self.connections.query_header.set(name, query_header_context)
            self.acquire_connection(name)
            yield
        finally:
@@ -267,11 +315,6 @@ class BaseAdapter(metaclass=AdapterMeta):
            if self.connections.query_header is not None:
                self.connections.query_header.reset()

-    @contextmanager
-    def connection_for(self, node: ResultNode) -> Iterator[None]:
-        with self.connection_named(node.unique_id, node):
-            yield
-
    @available.parse(lambda *a, **k: ("", empty_table()))
    def execute(
        self, sql: str, auto_begin: bool = False, fetch: bool = False, limit: Optional[int] = None
@@ -315,14 +358,21 @@ class BaseAdapter(metaclass=AdapterMeta):

    @available.parse(lambda *a, **k: ("", empty_table()))
    def get_partitions_metadata(self, table: str) -> Tuple[agate.Table]:
-        """Obtain partitions metadata for a BigQuery partitioned table.
+        """
+        TODO: Can we move this to dbt-bigquery?
+        Obtain partitions metadata for a BigQuery partitioned table.

-        :param str table_id: a partitioned table id, in standard SQL format.
+        :param str table: a partitioned table id, in standard SQL format.
        :return: a partition metadata tuple, as described in
            https://cloud.google.com/bigquery/docs/creating-partitioned-tables#getting_partition_metadata_using_meta_tables.
        :rtype: agate.Table
        """
-        return self.connections.get_partitions_metadata(table=table)
+        if hasattr(self.connections, "get_partitions_metadata"):
+            return self.connections.get_partitions_metadata(table=table)
+        else:
+            raise NotImplementedError(
+                "`get_partitions_metadata` is not implemented for this adapter!"
+            )

    ###
    # Methods that should never be overridden
@@ -337,39 +387,6 @@ class BaseAdapter(metaclass=AdapterMeta):
        """
        return cls.ConnectionManager.TYPE

-    @property
-    def _macro_manifest(self) -> MacroManifest:
-        if self._macro_manifest_lazy is None:
-            return self.load_macro_manifest()
-        return self._macro_manifest_lazy
-
-    def check_macro_manifest(self) -> Optional[MacroManifest]:
-        """Return the internal manifest (used for executing macros) if it's
-        been initialized, otherwise return None.
-        """
-        return self._macro_manifest_lazy
-
-    def load_macro_manifest(self, base_macros_only=False) -> MacroManifest:
-        # base_macros_only is for the test framework
-        if self._macro_manifest_lazy is None:
-            # avoid a circular import
-            from dbt.parser.manifest import ManifestLoader
-
-            manifest = ManifestLoader.load_macros(
-                self.config,
-                self.connections.set_query_header,
-                base_macros_only=base_macros_only,
-            )
-            # TODO CT-211
-            self._macro_manifest_lazy = manifest  # type: ignore[assignment]
-        # TODO CT-211
-        return self._macro_manifest_lazy  # type: ignore[return-value]
-
-    def clear_macro_manifest(self):
-        if self._macro_manifest_lazy is not None:
-            self._macro_manifest_lazy = None
-
-    ###
    # Caching methods
    ###
    def _schema_is_cached(self, database: Optional[str], schema: str) -> bool:
@@ -387,18 +404,16 @@ class BaseAdapter(metaclass=AdapterMeta):
        else:
            return True

-    def _get_cache_schemas(self, manifest: Manifest) -> Set[BaseRelation]:
+    def _get_cache_schemas(self, relation_configs: Iterable[RelationConfig]) -> Set[BaseRelation]:
        """Get the set of schema relations that the cache logic needs to
-        populate. This means only executable nodes are included.
+        populate.
        """
-        # the cache only cares about executable nodes
        return {
-            self.Relation.create_from(self.config, node).without_identifier()
-            for node in manifest.nodes.values()
-            if (node.is_relational and not node.is_ephemeral_model and not node.is_external_node)
+            self.Relation.create_from(quoting=self.config, relation_config=relation_config)
+            for relation_config in relation_configs
        }

-    def _get_catalog_schemas(self, manifest: Manifest) -> SchemaSearchMap:
+    def _get_catalog_schemas(self, relation_configs: Iterable[RelationConfig]) -> SchemaSearchMap:
        """Get a mapping of each node's "information_schema" relations to a
        set of all schemas expected in that information_schema.

@@ -408,16 +423,8 @@ class BaseAdapter(metaclass=AdapterMeta):
        lowercase strings.
        """
        info_schema_name_map = SchemaSearchMap()
-        nodes: Iterator[ResultNode] = chain(
-            [
-                node
-                for node in manifest.nodes.values()
-                if (node.is_relational and not node.is_ephemeral_model)
-            ],
-            manifest.sources.values(),
-        )
-        for node in nodes:
-            relation = self.Relation.create_from(self.config, node)
+        relations = self._get_catalog_relations(relation_configs)
+        for relation in relations:
            info_schema_name_map.add(relation)
        # result is a map whose keys are information_schema Relations without
        # identifiers that have appropriate database prefixes, and whose values
@@ -425,14 +432,37 @@ class BaseAdapter(metaclass=AdapterMeta):
        # databases
        return info_schema_name_map

+    def _get_catalog_relations_by_info_schema(
+        self, relations
+    ) -> Dict[InformationSchema, List[BaseRelation]]:
+        relations_by_info_schema: Dict[InformationSchema, List[BaseRelation]] = dict()
+        for relation in relations:
+            info_schema = relation.information_schema_only()
+            if info_schema not in relations_by_info_schema:
+                relations_by_info_schema[info_schema] = []
+            relations_by_info_schema[info_schema].append(relation)
+
+        return relations_by_info_schema
+
+    def _get_catalog_relations(
+        self, relation_configs: Iterable[RelationConfig]
+    ) -> List[BaseRelation]:
+        relations = [
+            self.Relation.create_from(quoting=self.config, relation_config=relation_config)
+            for relation_config in relation_configs
+        ]
+        return relations
+
    def _relations_cache_for_schemas(
-        self, manifest: Manifest, cache_schemas: Optional[Set[BaseRelation]] = None
+        self,
+        relation_configs: Iterable[RelationConfig],
+        cache_schemas: Optional[Set[BaseRelation]] = None,
    ) -> None:
        """Populate the relations cache for the given schemas. Returns an
        iterable of the schemas populated, as strings.
        """
        if not cache_schemas:
-            cache_schemas = self._get_cache_schemas(manifest)
+            cache_schemas = self._get_cache_schemas(relation_configs)
        with executor(self.config) as tpe:
            futures: List[Future[List[BaseRelation]]] = []
            for cache_schema in cache_schemas:
@@ -453,14 +483,15 @@ class BaseAdapter(metaclass=AdapterMeta):
        # it's possible that there were no relations in some schemas. We want
        # to insert the schemas we query into the cache's `.schemas` attribute
        # so we can check it later
-        cache_update: Set[Tuple[Optional[str], Optional[str]]] = set()
+        cache_update: Set[Tuple[Optional[str], str]] = set()
        for relation in cache_schemas:
-            cache_update.add((relation.database, relation.schema))
+            if relation.schema:
+                cache_update.add((relation.database, relation.schema))
        self.cache.update_schemas(cache_update)

    def set_relations_cache(
        self,
-        manifest: Manifest,
+        relation_configs: Iterable[RelationConfig],
        clear: bool = False,
        required_schemas: Optional[Set[BaseRelation]] = None,
    ) -> None:
@@ -470,7 +501,7 @@ class BaseAdapter(metaclass=AdapterMeta):
        with self.cache.lock:
            if clear:
                self.cache.clear()
-            self._relations_cache_for_schemas(manifest, required_schemas)
+            self._relations_cache_for_schemas(relation_configs, required_schemas)

    @available
    def cache_added(self, relation: Optional[BaseRelation]) -> str:
@@ -917,6 +948,17 @@ class BaseAdapter(metaclass=AdapterMeta):
        """
        raise NotImplementedError("`convert_number_type` is not implemented for this adapter!")

+    @classmethod
+    def convert_integer_type(cls, agate_table: agate.Table, col_idx: int) -> str:
+        """Return the type in the database that best maps to the agate.Number
+        type for the given agate table and column index.
+
+        :param agate_table: The table
+        :param col_idx: The index into the agate table for the column.
+        :return: The name of the type in the database
+        """
+        return "integer"
+
    @classmethod
    @abc.abstractmethod
    def convert_boolean_type(cls, agate_table: agate.Table, col_idx: int) -> str:
@@ -974,6 +1016,7 @@ class BaseAdapter(metaclass=AdapterMeta):
    def convert_agate_type(cls, agate_table: agate.Table, col_idx: int) -> Optional[str]:
        agate_type: Type = agate_table.column_types[col_idx]
        conversions: List[Tuple[Type, Callable[..., str]]] = [
+            (Integer, cls.convert_integer_type),
            (agate.Text, cls.convert_text_type),
            (agate.Number, cls.convert_number_type),
            (agate.Boolean, cls.convert_boolean_type),
@@ -993,11 +1036,10 @@ class BaseAdapter(metaclass=AdapterMeta):
    def execute_macro(
        self,
        macro_name: str,
-        manifest: Optional[Manifest] = None,
+        macro_client: Optional[MacroClient] = None,
        project: Optional[str] = None,
        context_override: Optional[Dict[str, Any]] = None,
        kwargs: Optional[Dict[str, Any]] = None,
-        text_only_columns: Optional[Iterable[str]] = None,
    ) -> AttrDict:
        """Look macro_name up in the manifest and execute its results.

@@ -1017,13 +1059,11 @@ class BaseAdapter(metaclass=AdapterMeta):
        if context_override is None:
            context_override = {}

-        if manifest is None:
-            # TODO CT-211
-            manifest = self._macro_manifest  # type: ignore[assignment]
-        # TODO CT-211
-        macro = manifest.find_macro_by_name(  # type: ignore[union-attr]
-            macro_name, self.config.project_name, project
-        )
+        client = self._macro_client or macro_client
+        if client is None:
+            raise DbtInternalError("Macro client was None when calling execute_macro!")
+
+        macro = client.find_macro_by_name(macro_name, self.config.project_name, project)
        if macro is None:
            if project is None:
                package_name = "any package"
@@ -1035,27 +1075,20 @@ class BaseAdapter(metaclass=AdapterMeta):
                    macro_name, package_name
                )
            )
-        # This causes a reference cycle, as generate_runtime_macro_context()
-        # ends up calling get_adapter, so the import has to be here.
-        from dbt.context.providers import generate_runtime_macro_context

-        macro_context = generate_runtime_macro_context(
-            # TODO CT-211
-            macro=macro,
-            config=self.config,
-            manifest=manifest,  # type: ignore[arg-type]
-            package_name=project,
-        )
+        macro_context = client.generate_context_for_macro(self.config, macro, project)
        macro_context.update(context_override)

-        macro_function = MacroGenerator(macro, macro_context)
+        macro_function = CallableMacroGenerator(macro, macro_context)

        with self.connections.exception_handler(f"macro {macro_name}"):
            result = macro_function(**kwargs)
        return result

    @classmethod
-    def _catalog_filter_table(cls, table: agate.Table, manifest: Manifest) -> agate.Table:
+    def _catalog_filter_table(
+        cls, table: agate.Table, used_schemas: FrozenSet[Tuple[str, str]]
+    ) -> agate.Table:
        """Filter the table as appropriate for catalog entries. Subclasses can
        override this to change filtering rules on a per-adapter basis.
        """
@@ -1065,44 +1098,122 @@ class BaseAdapter(metaclass=AdapterMeta):
            table.column_names,
            text_only_columns=["table_database", "table_schema", "table_name"],
        )
-        return table.where(_catalog_filter_schemas(manifest))
+        return table.where(_catalog_filter_schemas(used_schemas))

    def _get_one_catalog(
        self,
        information_schema: InformationSchema,
        schemas: Set[str],
-        manifest: Manifest,
+        used_schemas: FrozenSet[Tuple[str, str]],
    ) -> agate.Table:
        kwargs = {"information_schema": information_schema, "schemas": schemas}
-        table = self.execute_macro(
-            GET_CATALOG_MACRO_NAME,
-            kwargs=kwargs,
-            # pass in the full manifest so we get any local project
-            # overrides
-            manifest=manifest,
-        )
+        table = self.execute_macro(GET_CATALOG_MACRO_NAME, kwargs=kwargs)

-        results = self._catalog_filter_table(table, manifest)  # type: ignore[arg-type]
+        results = self._catalog_filter_table(table, used_schemas)  # type: ignore[arg-type]
        return results

-    def get_catalog(self, manifest: Manifest) -> Tuple[agate.Table, List[Exception]]:
-        schema_map = self._get_catalog_schemas(manifest)
+    def _get_one_catalog_by_relations(
+        self,
+        information_schema: InformationSchema,
+        relations: List[BaseRelation],
+        used_schemas: FrozenSet[Tuple[str, str]],
+    ) -> agate.Table:

+        kwargs = {
+            "information_schema": information_schema,
+            "relations": relations,
+        }
+        table = self.execute_macro(GET_CATALOG_RELATIONS_MACRO_NAME, kwargs=kwargs)
+
+        results = self._catalog_filter_table(table, used_schemas)  # type: ignore[arg-type]
+        return results
+
+    def get_filtered_catalog(
+        self,
+        relation_configs: Iterable[RelationConfig],
+        used_schemas: FrozenSet[Tuple[str, str]],
+        relations: Optional[Set[BaseRelation]] = None,
+    ):
+        catalogs: agate.Table
+        if (
+            relations is None
+            or len(relations) > 100
+            or not self.supports(Capability.SchemaMetadataByRelations)
+        ):
+            # Do it the traditional way. We get the full catalog.
+            catalogs, exceptions = self.get_catalog(relation_configs, used_schemas)
+        else:
+            # Do it the new way. We try to save time by selecting information
+            # only for the exact set of relations we are interested in.
+            catalogs, exceptions = self.get_catalog_by_relations(used_schemas, relations)
+
+        if relations and catalogs:
+            relation_map = {
+                (
+                    r.database.casefold() if r.database else None,
+                    r.schema.casefold() if r.schema else None,
+                    r.identifier.casefold() if r.identifier else None,
+                )
+                for r in relations
+            }
+
+            def in_map(row: agate.Row):
+                d = _expect_row_value("table_database", row)
+                s = _expect_row_value("table_schema", row)
+                i = _expect_row_value("table_name", row)
+                d = d.casefold() if d is not None else None
+                s = s.casefold() if s is not None else None
+                i = i.casefold() if i is not None else None
+                return (d, s, i) in relation_map
+
+            catalogs = catalogs.where(in_map)
+
+        return catalogs, exceptions
+
+    def row_matches_relation(self, row: agate.Row, relations: Set[BaseRelation]):
+        pass
+
+    def get_catalog(
+        self,
+        relation_configs: Iterable[RelationConfig],
+        used_schemas: FrozenSet[Tuple[str, str]],
+    ) -> Tuple[agate.Table, List[Exception]]:
        with executor(self.config) as tpe:
            futures: List[Future[agate.Table]] = []
+            schema_map: SchemaSearchMap = self._get_catalog_schemas(relation_configs)
            for info, schemas in schema_map.items():
                if len(schemas) == 0:
                    continue
                name = ".".join([str(info.database), "information_schema"])
-
                fut = tpe.submit_connected(
-                    self, name, self._get_one_catalog, info, schemas, manifest
+                    self, name, self._get_one_catalog, info, schemas, used_schemas
+                )
+                futures.append(fut)
+
+        catalogs, exceptions = catch_as_completed(futures)
+        return catalogs, exceptions
+
+    def get_catalog_by_relations(
+        self, used_schemas: FrozenSet[Tuple[str, str]], relations: Set[BaseRelation]
+    ) -> Tuple[agate.Table, List[Exception]]:
+        with executor(self.config) as tpe:
+            futures: List[Future[agate.Table]] = []
+            relations_by_schema = self._get_catalog_relations_by_info_schema(relations)
+            for info_schema in relations_by_schema:
+                name = ".".join([str(info_schema.database), "information_schema"])
+                relations = set(relations_by_schema[info_schema])
+                fut = tpe.submit_connected(
+                    self,
+                    name,
+                    self._get_one_catalog_by_relations,
+                    info_schema,
+                    relations,
+                    used_schemas,
                )
                futures.append(fut)

            catalogs, exceptions = catch_as_completed(futures)
-
-        return catalogs, exceptions
+            return catalogs, exceptions

    def cancel_open_connections(self):
        """Cancel all open connections."""
@@ -1113,8 +1224,8 @@ class BaseAdapter(metaclass=AdapterMeta):
        source: BaseRelation,
        loaded_at_field: str,
        filter: Optional[str],
-        manifest: Optional[Manifest] = None,
-    ) -> Tuple[Optional[AdapterResponse], Dict[str, Any]]:
+        macro_client: Optional[MacroClient] = None,
+    ) -> Tuple[Optional[AdapterResponse], FreshnessResponse]:
        """Calculate the freshness of sources in dbt, and return it"""
        kwargs: Dict[str, Any] = {
            "source": source,
@@ -1129,9 +1240,9 @@ class BaseAdapter(metaclass=AdapterMeta):
            AttrDict,  # current: contains AdapterResponse + agate.Table
            agate.Table,  # previous: just table
        ]
-        result = self.execute_macro(FRESHNESS_MACRO_NAME, kwargs=kwargs, manifest=manifest)
+        result = self.execute_macro(FRESHNESS_MACRO_NAME, kwargs=kwargs, macro_client=macro_client)
        if isinstance(result, agate.Table):
-            deprecations.warn("collect-freshness-return-signature")
+            warn_or_error(CollectFreshnessReturnSignature())
            adapter_response = None
            table = result
        else:
@@ -1149,13 +1260,52 @@ class BaseAdapter(metaclass=AdapterMeta):

        snapshotted_at = _utc(table[0][1], source, loaded_at_field)
        age = (snapshotted_at - max_loaded_at).total_seconds()
-        freshness = {
+        freshness: FreshnessResponse = {
            "max_loaded_at": max_loaded_at,
            "snapshotted_at": snapshotted_at,
            "age": age,
        }
        return adapter_response, freshness

+    def calculate_freshness_from_metadata(
+        self,
+        source: BaseRelation,
+        macro_client: Optional[MacroClient] = None,
+    ) -> Tuple[Optional[AdapterResponse], FreshnessResponse]:
+        kwargs: Dict[str, Any] = {
+            "information_schema": source.information_schema_only(),
+            "relations": [source],
+        }
+        result = self.execute_macro(
+            GET_RELATION_LAST_MODIFIED_MACRO_NAME, kwargs=kwargs, macro_client=macro_client
+        )
+        adapter_response, table = result.response, result.table  # type: ignore[attr-defined]
+
+        try:
+            row = table[0]
+            last_modified_val = get_column_value_uncased("last_modified", row)
+            snapshotted_at_val = get_column_value_uncased("snapshotted_at", row)
+        except Exception:
+            raise MacroResultError(GET_RELATION_LAST_MODIFIED_MACRO_NAME, table)
+
+        if last_modified_val is None:
+            # Interpret missing value as "infinitely long ago"
+            max_loaded_at = datetime(1, 1, 1, 0, 0, 0, tzinfo=pytz.UTC)
+        else:
+            max_loaded_at = _utc(last_modified_val, None, "last_modified")
+
+        snapshotted_at = _utc(snapshotted_at_val, None, "snapshotted_at")
+
+        age = (snapshotted_at - max_loaded_at).total_seconds()
+
+        freshness: FreshnessResponse = {
+            "max_loaded_at": max_loaded_at,
+            "snapshotted_at": snapshotted_at,
+            "age": age,
+        }
+
+        return adapter_response, freshness
+
    def pre_model_hook(self, config: Mapping[str, Any]) -> Any:
        """A hook for running some operation before the model materialization
        runs. The hook can assume it has a connection available.
@@ -1181,11 +1331,6 @@ class BaseAdapter(metaclass=AdapterMeta):
        """
        pass

-    def get_compiler(self):
-        from dbt.compilation import Compiler
-
-        return Compiler(self.config)
-
    # Methods used in adapter tests
    def update_column_sql(
        self,
@@ -1305,7 +1450,7 @@ class BaseAdapter(metaclass=AdapterMeta):

        strategy = strategy.replace("+", "_")
        macro_name = f"get_incremental_{strategy}_sql"
-        # The model_context should have MacroGenerator callable objects for all macros
+        # The model_context should have callable objects for all macros
        if macro_name not in model_context:
            raise DbtRuntimeError(
                'dbt could not find an incremental strategy macro with the name "{}" in {}'.format(
@@ -1429,6 +1574,14 @@ class BaseAdapter(metaclass=AdapterMeta):
        else:
            return None

+    @classmethod
+    def capabilities(cls) -> CapabilityDict:
+        return cls._capabilities
+
+    @classmethod
+    def supports(cls, capability: Capability) -> bool:
+        return bool(cls.capabilities()[capability])
+

 COLUMNS_EQUAL_SQL = """
 with diff_count as (
--- a/core/dbt/adapters/base/meta.py
+++ b/core/dbt/adapters/base/meta.py
@@ -1,9 +1,8 @@
 import abc
 from functools import wraps
 from typing import Callable, Optional, Any, FrozenSet, Dict, Set
-
-from dbt.deprecations import warn, renamed_method
-
+from dbt.common.events.functions import warn_or_error
+from dbt.adapters.events.types import AdapterDeprecationWarning

 Decorator = Callable[[Any], Callable]

@@ -62,11 +61,12 @@ class _Available:

        def wrapper(func):
            func_name = func.__name__
-            renamed_method(func_name, supported_name)

            @wraps(func)
            def inner(*args, **kwargs):
-                warn("adapter:{}".format(func_name))
+                warn_or_error(
+                    AdapterDeprecationWarning(old_name=func_name, new_name=supported_name)
+                )
                return func(*args, **kwargs)

            if parse_replacement:
@@ -93,7 +93,7 @@ class AdapterMeta(abc.ABCMeta):
    _available_: FrozenSet[str]
    _parse_replacements_: Dict[str, Callable]

-    def __new__(mcls, name, bases, namespace, **kwargs):
+    def __new__(mcls, name, bases, namespace, **kwargs) -> "AdapterMeta":
        # mypy does not like the `**kwargs`. But `ABCMeta` itself takes
        # `**kwargs` in its argspec here (and passes them to `type.__new__`.
        # I'm not sure there is any benefit to it after poking around a bit,
--- a/core/dbt/adapters/base/plugin.py
+++ b/core/dbt/adapters/base/plugin.py
@@ -1,20 +1,10 @@
 from typing import List, Optional, Type
+from pathlib import Path

 from dbt.adapters.base import Credentials
-from dbt.exceptions import CompilationError
 from dbt.adapters.protocol import AdapterProtocol


-def project_name_from_path(include_path: str) -> str:
-    # avoid an import cycle
-    from dbt.config.project import PartialProject
-
-    partial = PartialProject.from_project_root(include_path)
-    if partial.project_name is None:
-        raise CompilationError(f"Invalid project at {include_path}: name not set!")
-    return partial.project_name
-
-
 class AdapterPlugin:
    """Defines the basic requirements for a dbt adapter plugin.

@@ -29,12 +19,13 @@ class AdapterPlugin:
        credentials: Type[Credentials],
        include_path: str,
        dependencies: Optional[List[str]] = None,
-    ):
+        project_name: Optional[str] = None,
+    ) -> None:

        self.adapter: Type[AdapterProtocol] = adapter
        self.credentials: Type[Credentials] = credentials
        self.include_path: str = include_path
-        self.project_name: str = project_name_from_path(include_path)
+        self.project_name: str = project_name or f"dbt_{Path(include_path).name}"
        self.dependencies: List[str]
        if dependencies is None:
            self.dependencies = []
--- a/core/dbt/adapters/base/query_headers.py
+++ b/core/dbt/adapters/base/query_headers.py
@@ -1,21 +1,20 @@
 from threading import local
 from typing import Optional, Callable, Dict, Any

-from dbt.clients.jinja import QueryStringGenerator
+from dbt.adapters.clients.jinja import QueryStringGenerator

 from dbt.context.manifest import generate_query_header_context
-from dbt.contracts.connection import AdapterRequiredConfig, QueryComment
-from dbt.contracts.graph.nodes import ResultNode
+from dbt.adapters.contracts.connection import AdapterRequiredConfig, QueryComment
 from dbt.contracts.graph.manifest import Manifest
-from dbt.exceptions import DbtRuntimeError
+from dbt.common.exceptions import DbtRuntimeError


-class NodeWrapper:
-    def __init__(self, node):
-        self._inner_node = node
+class QueryHeaderContextWrapper:
+    def __init__(self, context) -> None:
+        self._inner_context = context

    def __getattr__(self, name):
-        return getattr(self._inner_node, name, "")
+        return getattr(self._inner_context, name, "")


 class _QueryComment(local):
@@ -25,9 +24,9 @@ class _QueryComment(local):
        - a source_name indicating what set the current thread's query comment
    """

-    def __init__(self, initial):
+    def __init__(self, initial) -> None:
        self.query_comment: Optional[str] = initial
-        self.append = False
+        self.append: bool = False

    def add(self, sql: str) -> str:
        if not self.query_comment:
@@ -53,11 +52,11 @@ class _QueryComment(local):
        self.append = append


-QueryStringFunc = Callable[[str, Optional[NodeWrapper]], str]
+QueryStringFunc = Callable[[str, Optional[QueryHeaderContextWrapper]], str]


 class MacroQueryStringSetter:
-    def __init__(self, config: AdapterRequiredConfig, manifest: Manifest):
+    def __init__(self, config: AdapterRequiredConfig, manifest: Manifest) -> None:
        self.manifest = manifest
        self.config = config

@@ -90,10 +89,10 @@ class MacroQueryStringSetter:
    def reset(self):
        self.set("master", None)

-    def set(self, name: str, node: Optional[ResultNode]):
-        wrapped: Optional[NodeWrapper] = None
-        if node is not None:
-            wrapped = NodeWrapper(node)
+    def set(self, name: str, query_header_context: Any):
+        wrapped: Optional[QueryHeaderContextWrapper] = None
+        if query_header_context is not None:
+            wrapped = QueryHeaderContextWrapper(query_header_context)
        comment_str = self.generator(name, wrapped)

        append = False
--- a/core/dbt/adapters/base/relation.py
+++ b/core/dbt/adapters/base/relation.py
@@ -1,9 +1,9 @@
 from collections.abc import Hashable
 from dataclasses import dataclass, field
-from typing import Optional, TypeVar, Any, Type, Dict, Iterator, Tuple, Set
+from typing import Optional, TypeVar, Any, Type, Dict, Iterator, Tuple, Set, Union, FrozenSet

-from dbt.contracts.graph.nodes import SourceDefinition, ManifestNode, ResultNode, ParsedNode
-from dbt.contracts.relation import (
+from dbt.adapters.contracts.relation import (
+    RelationConfig,
    RelationType,
    ComponentName,
    HasQuoting,
@@ -11,18 +11,15 @@ from dbt.contracts.relation import (
    Policy,
    Path,
 )
-from dbt.exceptions import (
-    ApproximateMatchError,
-    DbtInternalError,
-    MultipleDatabasesNotAllowedError,
-)
-from dbt.node_types import NodeType
-from dbt.utils import filter_null_values, deep_merge, classproperty
+from dbt.adapters.exceptions import MultipleDatabasesNotAllowedError, ApproximateMatchError
+from dbt.common.utils import filter_null_values, deep_merge
+from dbt.adapters.utils import classproperty

-import dbt.exceptions
+import dbt.common.exceptions


 Self = TypeVar("Self", bound="BaseRelation")
+SerializableIterable = Union[Tuple, FrozenSet]


@dataclass(frozen=True, eq=False, repr=False)
@@ -35,6 +32,19 @@ class BaseRelation(FakeAPIObject, Hashable):
    include_policy: Policy = field(default_factory=lambda: Policy())
    quote_policy: Policy = field(default_factory=lambda: Policy())
    dbt_created: bool = False
+    limit: Optional[int] = None
+
+    # register relation types that can be renamed for the purpose of replacing relations using stages and backups
+    # adding a relation type here also requires defining the associated rename macro
+    # e.g. adding RelationType.View in dbt-postgres requires that you define:
+    # include/postgres/macros/relations/view/rename.sql::postgres__get_rename_view_sql()
+    renameable_relations: SerializableIterable = ()
+
+    # register relation types that are atomically replaceable, e.g. they have "create or replace" syntax
+    # adding a relation type here also requires defining the associated replace macro
+    # e.g. adding RelationType.View in dbt-postgres requires that you define:
+    # include/postgres/macros/relations/view/replace.sql::postgres__get_replace_view_sql()
+    replaceable_relations: SerializableIterable = ()

    def _is_exactish_match(self, field: ComponentName, value: str) -> bool:
        if self.dbt_created and self.quote_policy.get_part(field) is False:
@@ -87,7 +97,7 @@ class BaseRelation(FakeAPIObject, Hashable):

        if not search:
            # nothing was passed in
-            raise dbt.exceptions.DbtRuntimeError(
+            raise dbt.common.exceptions.DbtRuntimeError(
                "Tried to match relation, but no search path was passed!"
            )

@@ -169,7 +179,6 @@ class BaseRelation(FakeAPIObject, Hashable):
        return self.include(identifier=False).replace_path(identifier=None)

    def _render_iterator(self) -> Iterator[Tuple[Optional[ComponentName], Optional[str]]]:
-
        for key in ComponentName:
            path_part: Optional[str] = None
            if self.include_policy.get_part(key):
@@ -182,88 +191,65 @@ class BaseRelation(FakeAPIObject, Hashable):
        # if there is nothing set, this will return the empty string.
        return ".".join(part for _, part in self._render_iterator() if part is not None)

+    def render_limited(self) -> str:
+        rendered = self.render()
+        if self.limit is None:
+            return rendered
+        elif self.limit == 0:
+            return f"(select * from {rendered} where false limit 0) _dbt_limit_subq"
+        else:
+            return f"(select * from {rendered} limit {self.limit}) _dbt_limit_subq"
+
    def quoted(self, identifier):
        return "{quote_char}{identifier}{quote_char}".format(
            quote_char=self.quote_character,
            identifier=identifier,
        )

-    @classmethod
-    def create_from_source(cls: Type[Self], source: SourceDefinition, **kwargs: Any) -> Self:
-        source_quoting = source.quoting.to_dict(omit_none=True)
-        source_quoting.pop("column", None)
-        quote_policy = deep_merge(
-            cls.get_default_quote_policy().to_dict(omit_none=True),
-            source_quoting,
-            kwargs.get("quote_policy", {}),
-        )
-
-        return cls.create(
-            database=source.database,
-            schema=source.schema,
-            identifier=source.identifier,
-            quote_policy=quote_policy,
-            **kwargs,
-        )
-
    @staticmethod
    def add_ephemeral_prefix(name: str):
        return f"__dbt__cte__{name}"

    @classmethod
-    def create_ephemeral_from_node(
+    def create_ephemeral_from(
        cls: Type[Self],
-        config: HasQuoting,
-        node: ManifestNode,
+        relation_config: RelationConfig,
+        limit: Optional[int],
    ) -> Self:
        # Note that ephemeral models are based on the name.
-        identifier = cls.add_ephemeral_prefix(node.name)
+        identifier = cls.add_ephemeral_prefix(relation_config.name)
        return cls.create(
            type=cls.CTE,
            identifier=identifier,
+            limit=limit,
        ).quote(identifier=False)

-    @classmethod
-    def create_from_node(
-        cls: Type[Self],
-        config: HasQuoting,
-        node,
-        quote_policy: Optional[Dict[str, bool]] = None,
-        **kwargs: Any,
-    ) -> Self:
-        if quote_policy is None:
-            quote_policy = {}
-
-        quote_policy = dbt.utils.merge(config.quoting, quote_policy)
-
-        return cls.create(
-            database=node.database,
-            schema=node.schema,
-            identifier=node.alias,
-            quote_policy=quote_policy,
-            **kwargs,
-        )
-
    @classmethod
    def create_from(
        cls: Type[Self],
-        config: HasQuoting,
-        node: ResultNode,
+        quoting: HasQuoting,
+        relation_config: RelationConfig,
        **kwargs: Any,
    ) -> Self:
-        if node.resource_type == NodeType.Source:
-            if not isinstance(node, SourceDefinition):
-                raise DbtInternalError(
-                    "type mismatch, expected SourceDefinition but got {}".format(type(node))
-                )
-            return cls.create_from_source(node, **kwargs)
-        else:
-            # Can't use ManifestNode here because of parameterized generics
-            if not isinstance(node, (ParsedNode)):
-                raise DbtInternalError(
-                    f"type mismatch, expected ManifestNode but got {type(node)}"
-                )
-            return cls.create_from_node(config, node, **kwargs)
+        quote_policy = kwargs.pop("quote_policy", {})
+
+        config_quoting = relation_config.quoting_dict
+        config_quoting.pop("column", None)
+        # precedence: kwargs quoting > relation config quoting > base quoting > default quoting
+        quote_policy = deep_merge(
+            cls.get_default_quote_policy().to_dict(omit_none=True),
+            quoting.quoting,
+            config_quoting,
+            quote_policy,
+        )
+
+        return cls.create(
+            database=relation_config.database,
+            schema=relation_config.schema,
+            identifier=relation_config.identifier,
+            quote_policy=quote_policy,
+            **kwargs,
+        )

    @classmethod
    def create(
@@ -286,6 +272,14 @@ class BaseRelation(FakeAPIObject, Hashable):
        )
        return cls.from_dict(kwargs)

+    @property
+    def can_be_renamed(self) -> bool:
+        return self.type in self.renameable_relations
+
+    @property
+    def can_be_replaced(self) -> bool:
+        return self.type in self.replaceable_relations
+
    def __repr__(self) -> str:
        return "<{} {}>".format(self.__class__.__name__, self.render())

@@ -293,7 +287,7 @@ class BaseRelation(FakeAPIObject, Hashable):
        return hash(self.render())

    def __str__(self) -> str:
-        return self.render()
+        return self.render() if self.limit is None else self.render_limited()

    @property
    def database(self) -> Optional[str]:
@@ -366,7 +360,7 @@ class InformationSchema(BaseRelation):

    def __post_init__(self):
        if not isinstance(self.information_schema_view, (type(None), str)):
-            raise dbt.exceptions.CompilationError(
+            raise dbt.common.exceptions.CompilationError(
                "Got an invalid name: {}".format(self.information_schema_view)
            )

@@ -439,11 +433,11 @@ class SchemaSearchMap(Dict[InformationSchema, Set[Optional[str]]]):
        self[key].add(schema)

    def search(self) -> Iterator[Tuple[InformationSchema, Optional[str]]]:
-        for information_schema_name, schemas in self.items():
+        for information_schema, schemas in self.items():
            for schema in schemas:
-                yield information_schema_name, schema
+                yield information_schema, schema

-    def flatten(self, allow_multiple_databases: bool = False):
+    def flatten(self, allow_multiple_databases: bool = False) -> "SchemaSearchMap":
        new = self.__class__()

        # make sure we don't have multiple databases if allow_multiple_databases is set to False
--- a/core/dbt/adapters/cache.py
+++ b/core/dbt/adapters/cache.py
@@ -7,17 +7,16 @@ from dbt.adapters.reference_keys import (
    _make_ref_key_dict,
    _ReferenceKey,
 )
-from dbt.exceptions import (
-    DependentLinkNotCachedError,
+from dbt.common.exceptions.cache import (
    NewNameAlreadyInCacheError,
-    NoneRelationFoundError,
    ReferencedLinkNotCachedError,
+    DependentLinkNotCachedError,
    TruncatedModelNameCausedCollisionError,
+    NoneRelationFoundError,
 )
-from dbt.events.functions import fire_event, fire_event_if
-from dbt.events.types import CacheAction, CacheDumpGraph
-from dbt.flags import get_flags
-from dbt.utils import lowercase
+from dbt.common.events.functions import fire_event, fire_event_if
+from dbt.adapters.events.types import CacheAction, CacheDumpGraph
+from dbt.common.utils.formatting import lowercase


 def dot_separated(key: _ReferenceKey) -> str:
@@ -38,8 +37,8 @@ class _CachedRelation:
    :attr BaseRelation inner: The underlying dbt relation.
    """

-    def __init__(self, inner):
-        self.referenced_by = {}
+    def __init__(self, inner) -> None:
+        self.referenced_by: Dict[_ReferenceKey, _CachedRelation] = {}
        self.inner = inner

    def __str__(self) -> str:
@@ -165,10 +164,11 @@ class RelationsCache:
    :attr Set[str] schemas: The set of known/cached schemas, all lowercased.
    """

-    def __init__(self) -> None:
+    def __init__(self, log_cache_events: bool = False) -> None:
        self.relations: Dict[_ReferenceKey, _CachedRelation] = {}
        self.lock = threading.RLock()
        self.schemas: Set[Tuple[Optional[str], Optional[str]]] = set()
+        self.log_cache_events = log_cache_events

    def add_schema(
        self,
@@ -318,10 +318,9 @@ class RelationsCache:

        :param BaseRelation relation: The underlying relation.
        """
-        flags = get_flags()
        cached = _CachedRelation(relation)
        fire_event_if(
-            flags.LOG_CACHE_EVENTS,
+            self.log_cache_events,
            lambda: CacheDumpGraph(before_after="before", action="adding", dump=self.dump_graph()),
        )
        fire_event(CacheAction(action="add_relation", ref_key=_make_ref_key_dict(cached)))
@@ -329,7 +328,7 @@ class RelationsCache:
        with self.lock:
            self._setdefault(cached)
        fire_event_if(
-            flags.LOG_CACHE_EVENTS,
+            self.log_cache_events,
            lambda: CacheDumpGraph(before_after="after", action="adding", dump=self.dump_graph()),
        )

@@ -454,9 +453,8 @@ class RelationsCache:
                ref_key_2=new_key._asdict(),
            )
        )
-        flags = get_flags()
        fire_event_if(
-            flags.LOG_CACHE_EVENTS,
+            self.log_cache_events,
            lambda: CacheDumpGraph(before_after="before", action="rename", dump=self.dump_graph()),
        )

@@ -467,7 +465,7 @@ class RelationsCache:
                self._setdefault(_CachedRelation(new))

        fire_event_if(
-            flags.LOG_CACHE_EVENTS,
+            self.log_cache_events,
            lambda: CacheDumpGraph(before_after="after", action="rename", dump=self.dump_graph()),
        )

--- a/core/dbt/adapters/capability.py
+++ b/core/dbt/adapters/capability.py
@@ -0,0 +1,52 @@
+from dataclasses import dataclass
+from enum import Enum
+from typing import Optional, DefaultDict, Mapping
+
+
+class Capability(str, Enum):
+    """Enumeration of optional adapter features which can be probed using BaseAdapter.capabilities()"""
+
+    SchemaMetadataByRelations = "SchemaMetadataByRelations"
+    """Indicates efficient support for retrieving schema metadata for a list of relations, rather than always retrieving
+    all the relations in a schema."""
+
+    TableLastModifiedMetadata = "TableLastModifiedMetadata"
+    """Indicates support for determining the time of the last table modification by querying database metadata."""
+
+
+class Support(str, Enum):
+    Unknown = "Unknown"
+    """The adapter has not declared whether this capability is a feature of the underlying DBMS."""
+
+    Unsupported = "Unsupported"
+    """This capability is not possible with the underlying DBMS, so the adapter does not implement related macros."""
+
+    NotImplemented = "NotImplemented"
+    """This capability is available in the underlying DBMS, but support has not yet been implemented in the adapter."""
+
+    Versioned = "Versioned"
+    """Some versions of the DBMS supported by the adapter support this capability and the adapter has implemented any
+    macros needed to use it."""
+
+    Full = "Full"
+    """All versions of the DBMS supported by the adapter support this capability and the adapter has implemented any
+    macros needed to use it."""
+
+
+@dataclass
+class CapabilitySupport:
+    support: Support
+    first_version: Optional[str] = None
+
+    def __bool__(self):
+        return self.support == Support.Versioned or self.support == Support.Full
+
+
+class CapabilityDict(DefaultDict[Capability, CapabilitySupport]):
+    def __init__(self, vals: Mapping[Capability, CapabilitySupport]):
+        super().__init__(self._default)
+        self.update(vals)
+
+    @staticmethod
+    def _default():
+        return CapabilitySupport(support=Support.Unknown)
--- a/third-party-stubs/mashumaro/dialects/init.pyi
+++ b/third-party-stubs/mashumaro/dialects/init.pyi
--- a/core/dbt/adapters/clients/jinja.py
+++ b/core/dbt/adapters/clients/jinja.py
@@ -0,0 +1,23 @@
+from typing import Dict, Any
+from dbt.common.clients.jinja import BaseMacroGenerator, get_environment
+
+
+class QueryStringGenerator(BaseMacroGenerator):
+    def __init__(self, template_str: str, context: Dict[str, Any]) -> None:
+        super().__init__(context)
+        self.template_str: str = template_str
+        env = get_environment()
+        self.template = env.from_string(
+            self.template_str,
+            globals=self.context,
+        )
+
+    def get_name(self) -> str:
+        return "query_comment_macro"
+
+    def get_template(self):
+        """Don't use the template cache, we don't have a node"""
+        return self.template
+
+    def __call__(self, connection_name: str, node) -> str:
+        return str(self.call_macro(connection_name, node))
--- a/core/dbt/adapters/contracts/init.py
+++ b/core/dbt/adapters/contracts/init.py
--- a/core/dbt/adapters/contracts/connection.py
+++ b/core/dbt/adapters/contracts/connection.py
@@ -11,31 +11,32 @@ from typing import (
    List,
    Callable,
 )
-from dbt.exceptions import DbtInternalError
-from dbt.utils import translate_aliases, md5
-from dbt.events.functions import fire_event
-from dbt.events.types import NewConnectionOpening
-from dbt.events.contextvars import get_node_info
-from typing_extensions import Protocol
-from dbt.dataclass_schema import (
+from typing_extensions import Protocol, Annotated
+
+from mashumaro.jsonschema.annotations import Pattern
+
+from dbt.adapters.utils import translate_aliases
+from dbt.common.exceptions import DbtInternalError
+from dbt.common.dataclass_schema import (
    dbtClassMixin,
    StrEnum,
    ExtensibleDbtClassMixin,
-    HyphenatedDbtClassMixin,
    ValidatedStringMixin,
-    register_pattern,
 )
-from dbt.contracts.util import Replaceable
+from dbt.common.contracts.util import Replaceable
+from dbt.common.utils import md5
+
+from dbt.common.events.functions import fire_event
+from dbt.adapters.events.types import NewConnectionOpening
+
+# TODO: this is a very bad dependency - shared global state
+from dbt.common.events.contextvars import get_node_info


 class Identifier(ValidatedStringMixin):
    ValidationRegex = r"^[A-Za-z_][A-Za-z0-9_]+$"


-# we need register_pattern for jsonschema validation
-register_pattern(Identifier, r"^[A-Za-z_][A-Za-z0-9_]+$")
-
-
@dataclass
 class AdapterResponse(dbtClassMixin):
    _message: str
@@ -55,7 +56,8 @@ class ConnectionState(StrEnum):

@dataclass(init=False)
 class Connection(ExtensibleDbtClassMixin, Replaceable):
-    type: Identifier
+    # Annotated is used by mashumaro for jsonschema generation
+    type: Annotated[Identifier, Pattern(r"^[A-Za-z_][A-Za-z0-9_]+$")]
    name: Optional[str] = None
    state: ConnectionState = ConnectionState.INIT
    transaction_open: bool = False
@@ -108,7 +110,7 @@ class LazyHandle:
    connection, updating the handle on the Connection.
    """

-    def __init__(self, opener: Callable[[Connection], Connection]):
+    def __init__(self, opener: Callable[[Connection], Connection]) -> None:
        self.opener = opener

    def resolve(self, connection: Connection) -> Connection:
@@ -161,6 +163,7 @@ class Credentials(ExtensibleDbtClassMixin, Replaceable, metaclass=abc.ABCMeta):
    @classmethod
    def __pre_deserialize__(cls, data):
        data = super().__pre_deserialize__(data)
+        # Need to fixup dbname => database, pass => password
        data = cls.translate_aliases(data)
        return data

@@ -220,10 +223,10 @@ DEFAULT_QUERY_COMMENT = """


@dataclass
-class QueryComment(HyphenatedDbtClassMixin):
+class QueryComment(dbtClassMixin):
    comment: str = DEFAULT_QUERY_COMMENT
    append: bool = False
-    job_label: bool = False
+    job_label: bool = field(default=False, metadata={"alias": "job-label"})


 class AdapterRequiredConfig(HasCredentials, Protocol):
@@ -231,3 +234,4 @@ class AdapterRequiredConfig(HasCredentials, Protocol):
    query_comment: QueryComment
    cli_vars: Dict[str, Any]
    target_path: str
+    log_cache_events: bool
--- a/core/dbt/adapters/contracts/macros.py
+++ b/core/dbt/adapters/contracts/macros.py
@@ -0,0 +1,16 @@
+from typing import Optional, Dict, Any
+from typing_extensions import Protocol
+
+from dbt.common.clients.jinja import MacroProtocol
+
+
+class MacroClient(Protocol):
+    def find_macro_by_name(
+        self, name: str, root_project_name: str, package: Optional[str]
+    ) -> Optional[MacroProtocol]:
+        raise NotImplementedError("find_macro_by_name not implemented")
+
+    def generate_context_for_macro(
+        self, config, macro: MacroProtocol, package: Optional[str]
+    ) -> Dict[str, Any]:
+        raise NotImplementedError("generate_context_for_macro not implemented")
--- a/core/dbt/adapters/contracts/relation.py
+++ b/core/dbt/adapters/contracts/relation.py
@@ -6,11 +6,11 @@ from typing import (
 )
 from typing_extensions import Protocol

-from dbt.dataclass_schema import dbtClassMixin, StrEnum
+from dbt.common.dataclass_schema import dbtClassMixin, StrEnum

-from dbt.contracts.util import Replaceable
-from dbt.exceptions import CompilationError, DataclassNotDictError
-from dbt.utils import deep_merge
+from dbt.common.contracts.util import Replaceable
+from dbt.common.exceptions import CompilationError, DataclassNotDictError
+from dbt.common.utils import deep_merge


 class RelationType(StrEnum):
@@ -19,6 +19,15 @@ class RelationType(StrEnum):
    CTE = "cte"
    MaterializedView = "materialized_view"
    External = "external"
+    Ephemeral = "ephemeral"
+
+
+class RelationConfig(Protocol):
+    name: str
+    database: str
+    schema: str
+    identifier: str
+    quoting_dict: Dict[str, bool]


 class ComponentName(StrEnum):
--- a/core/dbt/adapters/events/README.md
+++ b/core/dbt/adapters/events/README.md
@@ -0,0 +1,57 @@
+# Events Module
+The Events module is responsible for communicating internal dbt structures into a consumable interface. Because the "event" classes are based entirely on protobuf definitions, the interface is really clearly defined, whether or not protobufs are used to consume it. We use Betterproto for compiling the protobuf message definitions into Python classes.
+
+# Using the Events Module
+The event module provides types that represent what is happening in dbt in `events.types`. These types are intended to represent an exhaustive list of all things happening within dbt that will need to be logged, streamed, or printed. To fire an event, `common.events.functions::fire_event` is the entry point to the module from everywhere in dbt.
+
+# Logging
+When events are processed via `fire_event`, nearly everything is logged. Whether or not the user has enabled the debug flag, all debug messages are still logged to the file. However, some events are particularly time consuming to construct because they return a huge amount of data. Today, the only messages in this category are cache events and are only logged if the `--log-cache-events` flag is on. This is important because these messages should not be created unless they are going to be logged, because they cause a noticable performance degredation. These events use a "fire_event_if" functions.
+
+# Adding a New Event
+* Add a new message in types.proto, and a second message with the same name + "Msg". The "Msg" message should have two fields, an "info" field of EventInfo, and a "data" field referring to the message name without "Msg"
+* run the protoc compiler to update adapter_types_pb2.py:   make adapter_proto_types
+* Add a wrapping class in core/dbt/adapters/event/types.py with a Level superclass  plus code and message methods
+
+We have switched from using betterproto to using google protobuf, because of a lack of support for Struct fields in betterproto.
+
+The google protobuf interface is janky and very much non-Pythonic. The "generated" classes in types_pb2.py do not resemble regular Python classes. They do not have normal constructors; they can only be constructed empty. They can be "filled" by setting fields individually or using a json_format method like ParseDict.  We have wrapped the logging events with a class (in types.py) which allows using a constructor -- keywords only, no positional parameters. 
+
+## Required for Every Event
+
+- a method `code`, that's unique across events
+- assign a log level by using the Level mixin: `DebugLevel`, `InfoLevel`, `WarnLevel`, or `ErrorLevel`
+- a message()
+
+Example
+```
+class PartialParsingDeletedExposure(DebugLevel):
+    def code(self):
+        return "I049"
+
+    def message(self) -> str:
+        return f"Partial parsing: deleted exposure {self.unique_id}"
+
+```
+
+
+# Adapter Maintainers
+To integrate existing log messages from adapters, you likely have a line of code like this in your adapter already:
+```python
+from dbt.logger import GLOBAL_LOGGER as logger
+```
+
+Simply change it to these two lines with your adapter's database name, and all your existing call sites will now use the new system for v1.0:
+
+```python
+
+from dbt.adapter.events.logging import AdapterLogger
+
+logger = AdapterLogger("<database name>")
+# e.g. AdapterLogger("Snowflake")
+```
+
+## Compiling types.proto
+
+After adding a new message in `adapter_types.proto`, either:
+- In the repository root directory: `make adapter_proto_types`
+- In the `core/dbt/adapters/events` directory: `protoc -I=. --python_out=. types.proto`
--- a/core/dbt/adapters/events/init.py
+++ b/core/dbt/adapters/events/init.py
--- a/core/dbt/adapters/events/adapter_types.proto
+++ b/core/dbt/adapters/events/adapter_types.proto
@@ -0,0 +1,517 @@
+syntax = "proto3";
+
+package proto_types;
+
+import "google/protobuf/timestamp.proto";
+import "google/protobuf/struct.proto";
+
+// Common event info
+message AdapterCommonEventInfo {
+    string name = 1;
+    string code = 2;
+    string msg = 3;
+    string level = 4;
+    string invocation_id = 5;
+    int32 pid = 6;
+    string thread = 7;
+    google.protobuf.Timestamp ts = 8;
+    map<string, string> extra = 9;
+    string category = 10;
+}
+
+// AdapterNodeRelation
+message AdapterNodeRelation {
+    string database = 10;
+    string schema = 11;
+    string alias = 12;
+    string relation_name = 13;
+}
+
+// NodeInfo
+message AdapterNodeInfo {
+    string node_path = 1;
+    string node_name = 2;
+    string unique_id = 3;
+    string resource_type = 4;
+    string materialized = 5;
+    string node_status = 6;
+    string node_started_at = 7;
+    string node_finished_at = 8;
+    google.protobuf.Struct meta = 9;
+    AdapterNodeRelation node_relation = 10;
+}
+
+// ReferenceKey
+message ReferenceKeyMsg {
+    string database = 1;
+    string schema = 2;
+    string identifier = 3;
+}
+
+// D - Deprecations
+
+// D005
+message AdapterDeprecationWarning {
+    string old_name = 1;
+    string new_name = 2;
+}
+
+message AdapterDeprecationWarningMsg {
+    AdapterCommonEventInfo info = 1;
+    AdapterDeprecationWarning data = 2;
+}
+
+// D012
+message CollectFreshnessReturnSignature {
+}
+
+message CollectFreshnessReturnSignatureMsg {
+    AdapterCommonEventInfo info = 1;
+    CollectFreshnessReturnSignature data = 2;
+}
+
+// E - DB Adapter
+
+// E001
+message AdapterEventDebug {
+    AdapterNodeInfo node_info = 1;
+    string name = 2;
+    string base_msg = 3;
+    google.protobuf.ListValue args = 4;
+}
+
+message AdapterEventDebugMsg {
+    AdapterCommonEventInfo info = 1;
+    AdapterEventDebug data = 2;
+}
+
+// E002
+message AdapterEventInfo {
+    AdapterNodeInfo node_info = 1;
+    string name = 2;
+    string base_msg = 3;
+    google.protobuf.ListValue args = 4;
+}
+
+message AdapterEventInfoMsg {
+    AdapterCommonEventInfo info = 1;
+    AdapterEventInfo data = 2;
+}
+
+// E003
+message AdapterEventWarning {
+    AdapterNodeInfo node_info = 1;
+    string name = 2;
+    string base_msg = 3;
+    google.protobuf.ListValue args = 4;
+}
+
+message AdapterEventWarningMsg {
+    AdapterCommonEventInfo info = 1;
+    AdapterEventWarning data = 2;
+}
+
+// E004
+message AdapterEventError {
+    AdapterNodeInfo node_info = 1;
+    string name = 2;
+    string base_msg = 3;
+    google.protobuf.ListValue args = 4;
+    string exc_info = 5;
+}
+
+message AdapterEventErrorMsg {
+    AdapterCommonEventInfo info = 1;
+    AdapterEventError data = 2;
+}
+
+// E005
+message NewConnection {
+    AdapterNodeInfo node_info = 1;
+    string conn_type = 2;
+    string conn_name = 3;
+}
+
+message NewConnectionMsg {
+    AdapterCommonEventInfo info = 1;
+    NewConnection data = 2;
+}
+
+// E006
+message ConnectionReused {
+    string conn_name = 1;
+    string orig_conn_name = 2;
+}
+
+message ConnectionReusedMsg {
+    AdapterCommonEventInfo info = 1;
+    ConnectionReused data = 2;
+}
+
+// E007
+message ConnectionLeftOpenInCleanup {
+    string conn_name = 1;
+}
+
+message ConnectionLeftOpenInCleanupMsg {
+    AdapterCommonEventInfo info = 1;
+    ConnectionLeftOpenInCleanup data = 2;
+}
+
+// E008
+message ConnectionClosedInCleanup {
+    string conn_name = 1;
+}
+
+message ConnectionClosedInCleanupMsg {
+    AdapterCommonEventInfo info = 1;
+    ConnectionClosedInCleanup data = 2;
+}
+
+// E009
+message RollbackFailed {
+    AdapterNodeInfo node_info = 1;
+    string conn_name = 2;
+    string exc_info = 3;
+}
+
+message RollbackFailedMsg {
+    AdapterCommonEventInfo info = 1;
+    RollbackFailed data = 2;
+}
+
+// E010
+message ConnectionClosed {
+    AdapterNodeInfo node_info = 1;
+    string conn_name = 2;
+}
+
+message ConnectionClosedMsg {
+    AdapterCommonEventInfo info = 1;
+    ConnectionClosed data = 2;
+}
+
+// E011
+message ConnectionLeftOpen {
+    AdapterNodeInfo node_info = 1;
+    string conn_name = 2;
+}
+
+message ConnectionLeftOpenMsg {
+    AdapterCommonEventInfo info = 1;
+    ConnectionLeftOpen data = 2;
+}
+
+// E012
+message Rollback {
+    AdapterNodeInfo node_info = 1;
+    string conn_name = 2;
+}
+
+message RollbackMsg {
+    AdapterCommonEventInfo info = 1;
+    Rollback data = 2;
+}
+
+// E013
+message CacheMiss {
+    string conn_name = 1;
+    string database = 2;
+    string schema = 3;
+}
+
+message CacheMissMsg {
+    AdapterCommonEventInfo info = 1;
+    CacheMiss data = 2;
+}
+
+// E014
+message ListRelations {
+    string database = 1;
+    string schema = 2;
+    repeated ReferenceKeyMsg relations = 3;
+}
+
+message ListRelationsMsg {
+    AdapterCommonEventInfo info = 1;
+    ListRelations data = 2;
+}
+
+// E015
+message ConnectionUsed {
+    AdapterNodeInfo node_info = 1;
+    string conn_type = 2;
+    string conn_name = 3;
+}
+
+message ConnectionUsedMsg {
+    AdapterCommonEventInfo info = 1;
+    ConnectionUsed data = 2;
+}
+
+// E016
+message SQLQuery {
+    AdapterNodeInfo node_info = 1;
+    string conn_name = 2;
+    string sql = 3;
+}
+
+message SQLQueryMsg {
+    AdapterCommonEventInfo info = 1;
+    SQLQuery data = 2;
+}
+
+// E017
+message SQLQueryStatus {
+    AdapterNodeInfo node_info = 1;
+    string status = 2;
+    float elapsed = 3;
+}
+
+message SQLQueryStatusMsg {
+    AdapterCommonEventInfo info = 1;
+    SQLQueryStatus data = 2;
+}
+
+// E018
+message SQLCommit {
+    AdapterNodeInfo node_info = 1;
+    string conn_name = 2;
+}
+
+message SQLCommitMsg {
+    AdapterCommonEventInfo info = 1;
+    SQLCommit data = 2;
+}
+
+// E019
+message ColTypeChange {
+    string orig_type = 1;
+    string new_type = 2;
+    ReferenceKeyMsg table = 3;
+}
+
+message ColTypeChangeMsg {
+    AdapterCommonEventInfo info = 1;
+    ColTypeChange data = 2;
+}
+
+// E020
+message SchemaCreation {
+    ReferenceKeyMsg relation = 1;
+}
+
+message SchemaCreationMsg {
+    AdapterCommonEventInfo info = 1;
+    SchemaCreation data = 2;
+}
+
+// E021
+message SchemaDrop {
+    ReferenceKeyMsg relation = 1;
+}
+
+message SchemaDropMsg {
+    AdapterCommonEventInfo info = 1;
+    SchemaDrop data = 2;
+}
+
+// E022
+message CacheAction {
+    string action = 1;
+    ReferenceKeyMsg ref_key = 2;
+    ReferenceKeyMsg ref_key_2 = 3;
+    ReferenceKeyMsg ref_key_3 = 4;
+    repeated ReferenceKeyMsg ref_list = 5;
+}
+
+message CacheActionMsg {
+    AdapterCommonEventInfo info = 1;
+    CacheAction data = 2;
+}
+
+// Skipping E023, E024, E025, E026, E027, E028, E029, E0230
+
+// E031
+message CacheDumpGraph {
+    map<string, string> dump = 1;
+    string before_after = 2;
+    string action = 3;
+}
+
+message CacheDumpGraphMsg {
+    AdapterCommonEventInfo info = 1;
+    CacheDumpGraph data = 2;
+}
+
+
+// Skipping E032, E033, E034
+
+
+
+// E034
+message AdapterRegistered {
+    string adapter_name = 1;
+    string adapter_version = 2;
+}
+
+message AdapterRegisteredMsg {
+    AdapterCommonEventInfo info = 1;
+    AdapterRegistered data = 2;
+}
+
+// E035
+message AdapterImportError {
+    string exc = 1;
+}
+
+message AdapterImportErrorMsg {
+    AdapterCommonEventInfo info = 1;
+    AdapterImportError data = 2;
+}
+
+// E036
+message PluginLoadError {
+    string exc_info = 1;
+}
+
+message PluginLoadErrorMsg {
+    AdapterCommonEventInfo info = 1;
+    PluginLoadError data = 2;
+}
+
+// E037
+message NewConnectionOpening {
+    AdapterNodeInfo node_info = 1;
+    string connection_state = 2;
+}
+
+message NewConnectionOpeningMsg {
+    AdapterCommonEventInfo info = 1;
+    NewConnectionOpening data = 2;
+}
+
+// E038
+message CodeExecution {
+    string conn_name = 1;
+    string code_content = 2;
+}
+
+message CodeExecutionMsg {
+    AdapterCommonEventInfo info = 1;
+    CodeExecution data = 2;
+}
+
+// E039
+message CodeExecutionStatus {
+    string status = 1;
+    float elapsed = 2;
+}
+
+message CodeExecutionStatusMsg {
+    AdapterCommonEventInfo info = 1;
+    CodeExecutionStatus data = 2;
+}
+
+// E040
+message CatalogGenerationError {
+    string exc = 1;
+}
+
+message CatalogGenerationErrorMsg {
+    AdapterCommonEventInfo info = 1;
+    CatalogGenerationError data = 2;
+}
+
+// E041
+message WriteCatalogFailure {
+    int32 num_exceptions = 1;
+}
+
+message WriteCatalogFailureMsg {
+    AdapterCommonEventInfo info = 1;
+    WriteCatalogFailure data = 2;
+}
+
+// E042
+message CatalogWritten {
+    string path = 1;
+}
+
+message CatalogWrittenMsg {
+    AdapterCommonEventInfo info = 1;
+    CatalogWritten data = 2;
+}
+
+// E043
+message CannotGenerateDocs {
+}
+
+message CannotGenerateDocsMsg {
+    AdapterCommonEventInfo info = 1;
+    CannotGenerateDocs data = 2;
+}
+
+// E044
+message BuildingCatalog {
+}
+
+message BuildingCatalogMsg {
+    AdapterCommonEventInfo info = 1;
+    BuildingCatalog data = 2;
+}
+
+// E045
+message DatabaseErrorRunningHook {
+    string hook_type = 1;
+}
+
+message DatabaseErrorRunningHookMsg {
+    AdapterCommonEventInfo info = 1;
+    DatabaseErrorRunningHook data = 2;
+}
+
+// E046
+message HooksRunning {
+    int32 num_hooks = 1;
+    string hook_type = 2;
+}
+
+message HooksRunningMsg {
+    AdapterCommonEventInfo info = 1;
+    HooksRunning data = 2;
+}
+
+// E047
+message FinishedRunningStats {
+    string stat_line = 1;
+    string execution = 2;
+    float execution_time = 3;
+}
+
+message FinishedRunningStatsMsg {
+    AdapterCommonEventInfo info = 1;
+    FinishedRunningStats data = 2;
+}
+
+// E048
+message ConstraintNotEnforced {
+    string constraint = 1;
+    string adapter = 2;
+}
+
+message ConstraintNotEnforcedMsg {
+    AdapterCommonEventInfo info = 1;
+    ConstraintNotEnforced data = 2;
+}
+
+// E049
+message ConstraintNotSupported {
+    string constraint = 1;
+    string adapter = 2;
+}
+
+message ConstraintNotSupportedMsg {
+    AdapterCommonEventInfo info = 1;
+    ConstraintNotSupported data = 2;
+}
--- a/core/dbt/adapters/events/adapter_types_pb2.py
+++ b/core/dbt/adapters/events/adapter_types_pb2.py
--- a/Show More
+++ b/Show More