Skip to content

Commit

Permalink
style(snowflake): fix mypy error
Browse files Browse the repository at this point in the history
  • Loading branch information
Lee-W committed Nov 29, 2023
1 parent 150621f commit faece5b
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions astronomer/providers/snowflake/operators/snowflake.py
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ def execute(self, context: Context) -> None:
self.log.info("SQL after adding query tag: %s", self.sql)

hook = self.get_db_hook()
hook.run(self.sql, parameters=self.parameters) # type: ignore[arg-type]
hook.run(self.sql, parameters=self.parameters)
self.query_ids = hook.query_ids

if self.do_xcom_push:
Expand Down Expand Up @@ -350,9 +350,7 @@ def execute(self, context: Context) -> None:
token_life_time=self.token_life_time,
token_renewal_delta=self.token_renewal_delta,
)
hook.execute_query(
self.sql, statement_count=self.statement_count, bindings=self.bindings # type: ignore[arg-type]
)
hook.execute_query(self.sql, statement_count=self.statement_count, bindings=self.bindings)
self.query_ids = hook.query_ids
self.log.info("List of query ids %s", self.query_ids)

Expand Down

0 comments on commit faece5b

Please sign in to comment.