You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/08/02 19:36:58 UTC
[airflow] branch main updated: Fix odbc hook sqlalchemy_scheme docstring (#25421)
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 0f931c77c7 Fix odbc hook sqlalchemy_scheme docstring (#25421)
0f931c77c7 is described below
commit 0f931c77c75b49656e3709c649cd3ad70fe547fd
Author: gebo <bo...@gmail.com>
AuthorDate: Tue Aug 2 21:36:50 2022 +0200
Fix odbc hook sqlalchemy_scheme docstring (#25421)
---
airflow/providers/odbc/hooks/odbc.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/providers/odbc/hooks/odbc.py b/airflow/providers/odbc/hooks/odbc.py
index d5e288bb3d..63983fb117 100644
--- a/airflow/providers/odbc/hooks/odbc.py
+++ b/airflow/providers/odbc/hooks/odbc.py
@@ -80,8 +80,8 @@ class OdbcHook(DbApiHook):
return self._database or self.connection.schema
@property
- def sqlalchemy_scheme(self) -> Optional[str]:
- """Database provided in init if exists; otherwise, ``schema`` from ``Connection`` object."""
+ def sqlalchemy_scheme(self) -> str:
+ """Sqlalchemy scheme either from constructor, connection extras or default."""
return (
self._sqlalchemy_scheme
or self.connection_extra_lower.get('sqlalchemy_scheme')