This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new cdd2ba0 Fix mypy for exasol and facebook hooks (#20291)
cdd2ba0 is described below
commit cdd2ba032aa27b496c0e2cfa06ba45569d393401
Author: Kanthi <[email protected]>
AuthorDate: Sat Dec 18 12:11:14 2021 -0500
Fix mypy for exasol and facebook hooks (#20291)
---
airflow/providers/exasol/hooks/exasol.py | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/airflow/providers/exasol/hooks/exasol.py
b/airflow/providers/exasol/hooks/exasol.py
index 9f07351..55ea553 100644
--- a/airflow/providers/exasol/hooks/exasol.py
+++ b/airflow/providers/exasol/hooks/exasol.py
@@ -143,7 +143,9 @@ class ExasolHook(DbApiHook):
)
self.log.info("Data saved to %s", filename)
- def run(self, sql: Union[str, list], autocommit: bool = False, parameters:
Optional[dict] = None) -> None:
+ def run(
+ self, sql: Union[str, list], autocommit: bool = False, parameters:
Optional[dict] = None, handler=None
+ ) -> None:
"""
Runs a command or a list of commands. Pass a list of sql
statements to the sql parameter to get them to execute
@@ -157,6 +159,8 @@ class ExasolHook(DbApiHook):
:type autocommit: bool
:param parameters: The parameters to render the SQL query with.
:type parameters: dict or iterable
+ :param handler: The result handler which is called with the result of
each statement.
+ :type handler: callable
"""
if isinstance(sql, str):
sql = [sql]
