From 8eff6e4dd489a71e81faae3fce730dc73392b86c Mon Sep 17 00:00:00 2001 From: yoziru-desu Date: Mon, 7 Sep 2015 23:47:09 +0200 Subject: [PATCH] Update models.py add Oracle SQL support through the OracleHook --- airflow/models.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/airflow/models.py b/airflow/models.py index 84685c683b994..0ad6baba0a4f6 100644 --- a/airflow/models.py +++ b/airflow/models.py @@ -388,6 +388,8 @@ def get_hook(self): return hooks.JdbcHook(jdbc_conn_id=self.conn_id) elif self.conn_type == 'mssql': return hooks.MsSqlHook(mssql_conn_id=self.conn_id) + elif self.conn_type == 'oracle': + return hooks.OracleHook(oracle_conn_id=self.conn_id) except: return None