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')