diff --git a/dbt/adapters/upsolver/__version__.py b/dbt/adapters/upsolver/__version__.py index 3182945..7f3acb6 100644 --- a/dbt/adapters/upsolver/__version__.py +++ b/dbt/adapters/upsolver/__version__.py @@ -1 +1 @@ -version = "1.5.27" +version = "1.5.28" diff --git a/dbt/adapters/upsolver/impl.py b/dbt/adapters/upsolver/impl.py index bd28b43..453863b 100644 --- a/dbt/adapters/upsolver/impl.py +++ b/dbt/adapters/upsolver/impl.py @@ -144,8 +144,6 @@ def enrich_options(self, config_options, source, options_type): value = self.render_option_from_list_dict(value) enriched_options[option] = find_value enriched_options[option]['value'] = value - else: - logger.warning(f"Options not found: {option}") return enriched_options @available @@ -337,3 +335,16 @@ def is_expectation_exists(self, job_name, expectation_name): return True else: return False + + @available + def unique_options(self, options_1, options_2): + if options_1 and options_2: + options_1.update(options_2) + options = options_1 + elif options_1: + options = options_1 + elif options_2: + options = options_2 + else: + options = {} + return options diff --git a/dbt/include/upsolver/macros/materializations/incremental/create_copy_job.sql b/dbt/include/upsolver/macros/materializations/incremental/create_copy_job.sql index 048fda5..d41e212 100644 --- a/dbt/include/upsolver/macros/materializations/incremental/create_copy_job.sql +++ b/dbt/include/upsolver/macros/materializations/incremental/create_copy_job.sql @@ -21,8 +21,7 @@ SYNC {{''}} {%- endif -%} JOB {{job_identifier}} - {{ render_options(job_options, 'create') }} - {{ render_options(target_options, 'create') }} + {{ render_options(adapter.unique_options(job_options, target_options), 'create') }} AS COPY FROM {{source}} {{connection_identifier}} {{ render_options(source_options, 'create') }} INTO {{target_type}} {{into_relation}}