diff --git a/projects/vdk-plugins/vdk-trino/src/vdk/plugin/trino/trino_plugin.py b/projects/vdk-plugins/vdk-trino/src/vdk/plugin/trino/trino_plugin.py index c00fcb1950..45a6a3c1a4 100644 --- a/projects/vdk-plugins/vdk-trino/src/vdk/plugin/trino/trino_plugin.py +++ b/projects/vdk-plugins/vdk-trino/src/vdk/plugin/trino/trino_plugin.py @@ -76,7 +76,7 @@ def initialize_job(self, context: JobContext): ) context.templates.add_template( - "load/dimension/scd_upsert", + "scd_upsert", pathlib.Path(get_job_path("load/dimension/scd_upsert")), connection_name, )