diff --git a/dbt/include/postgres/macros/materializations/incremental_strategies.sql b/dbt/include/postgres/macros/materializations/incremental_strategies.sql index f41ed86..1d37366 100644 --- a/dbt/include/postgres/macros/materializations/incremental_strategies.sql +++ b/dbt/include/postgres/macros/materializations/incremental_strategies.sql @@ -9,7 +9,7 @@ {% endmacro %} -{% macro get_incremental_microbatch_sql(arg_dict) %} +{% macro postgres__get_incremental_microbatch_sql(arg_dict) %} {% if arg_dict["unique_key"] %} {% do return(adapter.dispatch('get_incremental_merge_sql', 'dbt')(arg_dict)) %} diff --git a/pyproject.toml b/pyproject.toml index e6848a4..0bf1fa1 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -56,8 +56,8 @@ path = "dbt/adapters/postgres/__version__.py" dependencies = [ "dbt-adapters @ git+https://github.com/dbt-labs/dbt-adapters.git", "dbt-common @ git+https://github.com/dbt-labs/dbt-common.git", - "dbt-tests-adapter @ git+https://github.com/dbt-labs/dbt-adapters.git#subdirectory=dbt-tests-adapter", - "dbt-core @ git+https://github.com/dbt-labs/dbt-core.git#subdirectory=core", + "dbt-tests-adapter @ git+https://github.com/dbt-labs/dbt-adapters.git@base-microbatch-tests#subdirectory=dbt-tests-adapter", + "dbt-core @ git+https://github.com/dbt-labs/dbt-core.git@event-time-ref-filtering#subdirectory=core", 'pre-commit==3.7.0;python_version>="3.9"', 'pre-commit==3.5.0;python_version=="3.8"', "freezegun", diff --git a/tests/functional/adapter/test_incremental_microbatch.py b/tests/functional/adapter/test_incremental_microbatch.py new file mode 100644 index 0000000..9d7083e --- /dev/null +++ b/tests/functional/adapter/test_incremental_microbatch.py @@ -0,0 +1,6 @@ +from dbt.tests.adapter.incremental.test_incremental_microbatch import ( + BaseMicrobatch, +) + +class TestPostgresMicrobatch(BaseMicrobatch): + pass