From 85292d38158bbc977f739568f21a98cf512b3199 Mon Sep 17 00:00:00 2001 From: Michelle Ark Date: Mon, 16 Sep 2024 12:31:26 -0400 Subject: [PATCH] Temporarily gate microbatch behind env var DBT_EXPERIMENTAL_MICROBATCH (#308) --- dbt/adapters/base/impl.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/dbt/adapters/base/impl.py b/dbt/adapters/base/impl.py index 310306ff..07b65c40 100644 --- a/dbt/adapters/base/impl.py +++ b/dbt/adapters/base/impl.py @@ -22,7 +22,7 @@ Union, TYPE_CHECKING, ) - +import os import pytz from dbt_common.behavior_flags import Behavior, BehaviorFlag from dbt_common.clients.jinja import CallableMacroGenerator @@ -1573,7 +1573,11 @@ def valid_incremental_strategies(self): return ["append"] def builtin_incremental_strategies(self): - return ["append", "delete+insert", "merge", "insert_overwrite", "microbatch"] + builtin_strategies = ["append", "delete+insert", "merge", "insert_overwrite"] + if os.environ.get("DBT_EXPERIMENTAL_MICROBATCH"): + builtin_strategies.append("microbatch") + + return builtin_strategies @available.parse_none def get_incremental_strategy_macro(self, model_context, strategy: str):