Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand All @@ -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 %}
Expand Down
Loading