diff --git a/integration_tests/tests/test_dbt_artifacts/test_microbatch_compiled_code.py b/integration_tests/tests/test_dbt_artifacts/test_microbatch_compiled_code.py index 98cabc80a..6c98d0389 100644 --- a/integration_tests/tests/test_dbt_artifacts/test_microbatch_compiled_code.py +++ b/integration_tests/tests/test_dbt_artifacts/test_microbatch_compiled_code.py @@ -100,7 +100,7 @@ def _with_microbatch_macro_file(dbt_project: DbtProject, macro_name: str): macro_path = dbt_project.project_dir_path / "macros" / "microbatch.sql" macro_sql = """ {% macro __MACRO_NAME__(arg_dict) %} - {{ return(elementary.get_incremental_microbatch_sql(arg_dict)) }} + {{ return(elementary.capture_and_execute_microbatch_compiled_code_sql(arg_dict)) }} {% endmacro %} """.replace( "__MACRO_NAME__", macro_name diff --git a/macros/edr/dbt_artifacts/microbatch/capture_microbatch_compiled_code.sql b/macros/edr/dbt_artifacts/microbatch/capture_microbatch_compiled_code.sql index 588c32cd5..47883612a 100644 --- a/macros/edr/dbt_artifacts/microbatch/capture_microbatch_compiled_code.sql +++ b/macros/edr/dbt_artifacts/microbatch/capture_microbatch_compiled_code.sql @@ -4,7 +4,7 @@ incremental strategy resolution in all projects. To apply this behavior, users should: 1) Override `get_incremental_microbatch_sql` in their own project and delegate to - `elementary.get_incremental_microbatch_sql(arg_dict)`. + `elementary.capture_and_execute_microbatch_compiled_code_sql(arg_dict)`. 2) Enable dbt behavior flag `require_batched_execution_for_custom_microbatch_strategy`. This flow is currently not supported for adapters: @@ -17,7 +17,7 @@ This flow is currently not supported for dbt Fusion. -#} -{% macro get_incremental_microbatch_sql(arg_dict) %} +{% macro capture_and_execute_microbatch_compiled_code_sql(arg_dict) %} {% if execute and model is defined %} {% do elementary.capture_microbatch_compiled_code_for_model() %} {% endif %}