Skip to content

Commit

Permalink
Merge branch 'person/sbuldeev/create-new-scd-custom-template' of http…
Browse files Browse the repository at this point in the history
…s://github.com/vmware/versatile-data-kit into person/sbuldeev/create-new-scd-custom-template
  • Loading branch information
sbuldeev committed Nov 29, 2024
2 parents f30595e + 2e0654d commit c771150
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 5 deletions.
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
CREATE TABLE "{target_schema_staging}"."{target_table_staging}" AS
(
SELECT t.*
SELECT t.*
FROM "{target_schema}"."{target_table}" AS t
LEFT JOIN "{source_schema}"."{source_view}" AS s ON s."{id_column}" = t."{id_column}"
WHERE s."{id_column}" IS NULL
)
UNION ALL
(
SELECT *
SELECT *
FROM "{source_schema}"."{source_view}"
)
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
#TODO Align with the upsert tempalte
# TODO Align with the upsert tempalte
# Copyright 2023-2024 Broadcom
# SPDX-License-Identifier: Apache-2.0
from vdk.api.job_input import IJobInput
Expand Down
2 changes: 0 additions & 2 deletions projects/vdk-plugins/vdk-trino/tests/test_vdk_templates.py
Original file line number Diff line number Diff line change
Expand Up @@ -631,7 +631,6 @@ def test_insert_clean_staging(self) -> None:
second_exec,
f"Clean up of staging table - {staging_table_name} is not made properly. Different data was found in the table after consecutive executions.",
)


def test_scd_upsert(self) -> None:
test_schema = self.__schema
Expand All @@ -657,7 +656,6 @@ def test_scd_upsert(self) -> None:
actual, expected, f"Elements in {expect_table} and {target_table} differ."
)


def __scd_upsert_execute(
self,
test_schema,
Expand Down

0 comments on commit c771150

Please sign in to comment.