You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by as...@apache.org on 2021/06/15 11:12:16 UTC

[airflow] branch main updated: Fix formatting and missing import (#16455)

This is an automated email from the ASF dual-hosted git repository.

ash 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 608dd0d  Fix formatting and missing import (#16455)
608dd0d is described below

commit 608dd0ddf65dac7f7eee2cb54628a93805b7ad66
Author: Ash Berlin-Taylor <as...@firemirror.com>
AuthorDate: Tue Jun 15 12:11:59 2021 +0100

    Fix formatting and missing import (#16455)
---
 airflow/providers/snowflake/hooks/snowflake.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/airflow/providers/snowflake/hooks/snowflake.py b/airflow/providers/snowflake/hooks/snowflake.py
index 6febfcc..0bb9bc5 100644
--- a/airflow/providers/snowflake/hooks/snowflake.py
+++ b/airflow/providers/snowflake/hooks/snowflake.py
@@ -15,6 +15,7 @@
 # KIND, either express or implied.  See the License for the
 # specific language governing permissions and limitations
 # under the License.
+import os
 from contextlib import closing
 from io import StringIO
 from typing import Any, Dict, Optional, Tuple, Union
@@ -180,7 +181,7 @@ class SnowflakeHook(DbApiHook):
             "authenticator": self.authenticator or authenticator,
             "session_parameters": self.session_parameters or session_parameters,
             # application is used to track origin of the requests
-            "application": os.environ.get("AIRFLOW_SNOWFLAKE_PARTNER", "AIRFLOW")
+            "application": os.environ.get("AIRFLOW_SNOWFLAKE_PARTNER", "AIRFLOW"),
         }
 
         # If private_key_file is specified in the extra json, load the contents of the file as a private