This is an automated email from the ASF dual-hosted git repository.
gopidesu 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 a751d64bf24 Fix unreachable code mypy warnings in sqlite provider
(#53433)
a751d64bf24 is described below
commit a751d64bf24c50b98f918a257b66b2aa474c16e2
Author: Jens Scheffler <[email protected]>
AuthorDate: Thu Jul 17 18:26:48 2025 +0200
Fix unreachable code mypy warnings in sqlite provider (#53433)
---
providers/sqlite/src/airflow/providers/sqlite/hooks/sqlite.py | 2 --
1 file changed, 2 deletions(-)
diff --git a/providers/sqlite/src/airflow/providers/sqlite/hooks/sqlite.py
b/providers/sqlite/src/airflow/providers/sqlite/hooks/sqlite.py
index 06a52efc2c6..4647a4b086e 100644
--- a/providers/sqlite/src/airflow/providers/sqlite/hooks/sqlite.py
+++ b/providers/sqlite/src/airflow/providers/sqlite/hooks/sqlite.py
@@ -47,8 +47,6 @@ class SqliteHook(DbApiHook):
def get_uri(self) -> str:
"""Override DbApiHook get_uri method for get_sqlalchemy_engine()."""
airflow_conn = self.get_connection(self.get_conn_id())
- if airflow_conn.conn_type is None:
- airflow_conn.conn_type = self.conn_type
airflow_uri = unquote(airflow_conn.get_uri())
# For sqlite, there is no schema in the connection URI. So we need to
drop the trailing slash.
airflow_sqlite_uri = airflow_uri.replace("/?", "?")
