From a7c938bd247842dadc80f25a8c3e6a663b922f7f Mon Sep 17 00:00:00 2001 From: Angelica Lastra Date: Mon, 23 Feb 2026 13:11:49 -0800 Subject: [PATCH 1/2] removed "_operator" suffix as it is deprecated syntax in Airflow 2.0. --- ea_airflow_util/dags/s3_to_snowflake_dag.py | 2 +- ea_airflow_util/dags/sftp_to_snowflake_dag.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ea_airflow_util/dags/s3_to_snowflake_dag.py b/ea_airflow_util/dags/s3_to_snowflake_dag.py index a9e8c71..af9f48a 100644 --- a/ea_airflow_util/dags/s3_to_snowflake_dag.py +++ b/ea_airflow_util/dags/s3_to_snowflake_dag.py @@ -1,6 +1,6 @@ import os -from airflow.operators.python_operator import PythonOperator +from airflow.operators.python import PythonOperator from airflow.providers.amazon.aws.operators.s3 import S3ListOperator from airflow.utils.helpers import chain diff --git a/ea_airflow_util/dags/sftp_to_snowflake_dag.py b/ea_airflow_util/dags/sftp_to_snowflake_dag.py index 599908d..b37d3c8 100644 --- a/ea_airflow_util/dags/sftp_to_snowflake_dag.py +++ b/ea_airflow_util/dags/sftp_to_snowflake_dag.py @@ -6,8 +6,8 @@ from airflow.exceptions import AirflowSkipException from airflow.providers.amazon.aws.hooks.s3 import S3Hook -from airflow.operators.bash_operator import BashOperator -from airflow.operators.python_operator import PythonOperator +from airflow.operators.bash import BashOperator +from airflow.operators.python import PythonOperator from airflow.providers.sftp.hooks.sftp import SFTPHook from airflow.utils.task_group import TaskGroup From 36567ed72e41e9f1cde2fd85821b6e35200e9c51 Mon Sep 17 00:00:00 2001 From: Angelica Lastra Date: Mon, 23 Feb 2026 13:12:26 -0800 Subject: [PATCH 2/2] removed apply_default decorators which was deprecated in 2.1 --- ea_airflow_util/providers/aws/operators/s3.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/ea_airflow_util/providers/aws/operators/s3.py b/ea_airflow_util/providers/aws/operators/s3.py index 795617e..c7e87d6 100644 --- a/ea_airflow_util/providers/aws/operators/s3.py +++ b/ea_airflow_util/providers/aws/operators/s3.py @@ -8,7 +8,6 @@ from airflow.models import BaseOperator from airflow.providers.amazon.aws.operators.s3 import S3FileTransformOperator from airflow.providers.snowflake.hooks.snowflake import SnowflakeHook -from airflow.utils.decorators import apply_defaults class LoopS3FileTransformOperator(S3FileTransformOperator): @@ -105,7 +104,6 @@ class S3ToSnowflakeOperator(BaseOperator): """ template_fields = ('s3_destination_key', 's3_destination_dir', 's3_destination_filename',) - @apply_defaults def __init__(self, *, snowflake_conn_id: str,