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 2021/05/19 05:47:15 UTC
[airflow] branch master updated: Add `template_fields` to
`S3ToSnowflake` operator (#15926)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/master by this push:
new 20f3639 Add `template_fields` to `S3ToSnowflake` operator (#15926)
20f3639 is described below
commit 20f363940316126e706923ee9caf7172dd4caeb6
Author: Nicolas Lecoy <ni...@gmail.com>
AuthorDate: Wed May 19 07:46:27 2021 +0200
Add `template_fields` to `S3ToSnowflake` operator (#15926)
---
airflow/providers/snowflake/transfers/s3_to_snowflake.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/airflow/providers/snowflake/transfers/s3_to_snowflake.py b/airflow/providers/snowflake/transfers/s3_to_snowflake.py
index be6e9a3..413b9e1 100644
--- a/airflow/providers/snowflake/transfers/s3_to_snowflake.py
+++ b/airflow/providers/snowflake/transfers/s3_to_snowflake.py
@@ -71,6 +71,9 @@ class S3ToSnowflakeOperator(BaseOperator):
:type session_parameters: dict
"""
+ template_fields = ("s3_keys",)
+ template_fields_renderers = {"s3_keys": "json"}
+
def __init__(
self,
*,