From fca4c596e945f91e06966a23fafd54150f70e7ad Mon Sep 17 00:00:00 2001 From: Michelle Ark Date: Thu, 5 Dec 2024 15:37:57 -0500 Subject: [PATCH] support MicrobatchConcurrency capability (#1259) (cherry picked from commit 86cf6e61b904a501d562d56d9fa1caea1c3efd7d) --- .changes/unreleased/Features-20241202-095136.yaml | 6 ++++++ dbt/adapters/snowflake/impl.py | 1 + setup.py | 2 +- 3 files changed, 8 insertions(+), 1 deletion(-) create mode 100644 .changes/unreleased/Features-20241202-095136.yaml diff --git a/.changes/unreleased/Features-20241202-095136.yaml b/.changes/unreleased/Features-20241202-095136.yaml new file mode 100644 index 000000000..973866a6d --- /dev/null +++ b/.changes/unreleased/Features-20241202-095136.yaml @@ -0,0 +1,6 @@ +kind: Features +body: Support MicrobatchConcurrency +time: 2024-12-02T09:51:36.606097-05:00 +custom: + Author: michelleark + Issue: "1260" diff --git a/dbt/adapters/snowflake/impl.py b/dbt/adapters/snowflake/impl.py index ac0d903db..10ad2a8a1 100644 --- a/dbt/adapters/snowflake/impl.py +++ b/dbt/adapters/snowflake/impl.py @@ -77,6 +77,7 @@ class SnowflakeAdapter(SQLAdapter): Capability.TableLastModifiedMetadata: CapabilitySupport(support=Support.Full), Capability.TableLastModifiedMetadataBatch: CapabilitySupport(support=Support.Full), Capability.GetCatalogForSingleRelation: CapabilitySupport(support=Support.Full), + Capability.MicrobatchConcurrency: CapabilitySupport(support=Support.Full), } ) diff --git a/setup.py b/setup.py index c0716341d..b237182ce 100644 --- a/setup.py +++ b/setup.py @@ -58,7 +58,7 @@ def _plugin_version() -> str: include_package_data=True, install_requires=[ "dbt-common>=1.10,<2.0", - "dbt-adapters>=1.7,<2.0", + "dbt-adapters>=1.10.4,<2.0", "snowflake-connector-python[secure-local-storage]~=3.0", # add dbt-core to ensure backwards compatibility of installation, this is not a functional dependency "dbt-core>=1.8.0",