Skip to content

Commit

Permalink
fix(snowflake): Trigger not working when selecting warehouse (#438)
Browse files Browse the repository at this point in the history
* fix(snowflake): Trigger not working when selecting warehouse

pass warehouse and database value to the Query task

* doc(snowflake): update trigger flow sample

#364
  • Loading branch information
mgabelle authored Nov 14, 2024
1 parent 46de7bd commit dddc145
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,7 @@
username: snowflake_user
password: snowflake_password
sql: "SELECT * FROM demo_db.public.customers"
warehouse: COMPUTE_WH
fetchType: FETCH
"""
)
Expand Down Expand Up @@ -79,6 +80,8 @@ protected AbstractJdbcQuery.Output runQuery(RunContext runContext) throws Except
.fetchType(this.getFetchType())
.fetchSize(this.getFetchSize())
.additionalVars(this.additionalVars)
.warehouse(this.getWarehouse())
.database(this.getDatabase())
.build();
return query.run(runContext);
}
Expand Down

0 comments on commit dddc145

Please sign in to comment.