[AIRFLOW-1107] Add support for ftps non-default port

Closes apache#2240 from jesusfcr/ftps
aminghadersohi · Apr 17, 2017 · 4d0c2f6 · 4d0c2f6
1 parent 4fb05d8
commit 4d0c2f6
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/airflow/contrib/hooks/ftp_hook.py b/airflow/contrib/hooks/ftp_hook.py
@@ -237,7 +237,12 @@ def get_conn(self):
         """
         if self.conn is None:
             params = self.get_connection(self.ftp_conn_id)
+
+            if params.port:
+               ftplib.FTP_TLS.port=params.port
+
             self.conn = ftplib.FTP_TLS(
                 params.host, params.login, params.password
             )
+
         return self.conn