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

eladkal 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 76021ef8cd Remove redundant Operator suffix from sensor name (#32475)
76021ef8cd is described below

commit 76021ef8cd630826d9524e9984d1a2a7d9c57549
Author: Tzu-ping Chung <[email protected]>
AuthorDate: Mon Jul 10 11:03:46 2023 +0800

    Remove redundant Operator suffix from sensor name (#32475)
    
    A Sensor is always an Operator, so adding 'Operator' to the class name
    is not needed. We have a check for this.
---
 airflow/providers/sftp/decorators/sensors/sftp.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/airflow/providers/sftp/decorators/sensors/sftp.py 
b/airflow/providers/sftp/decorators/sensors/sftp.py
index 990ebb53c9..9bdf670beb 100644
--- a/airflow/providers/sftp/decorators/sensors/sftp.py
+++ b/airflow/providers/sftp/decorators/sensors/sftp.py
@@ -23,7 +23,7 @@ from airflow.decorators.base import TaskDecorator, 
get_unique_task_id, task_deco
 from airflow.providers.sftp.sensors.sftp import SFTPSensor
 
 
-class _DecoratedSFTPSensorOperator(SFTPSensor):
+class _DecoratedSFTPSensor(SFTPSensor):
     """
     Wraps a Python callable and captures args/kwargs when called for execution.
 
@@ -67,6 +67,6 @@ def sftp_sensor_task(python_callable: Callable | None = None, 
**kwargs) -> TaskD
     return task_decorator_factory(
         python_callable=python_callable,
         multiple_outputs=False,
-        decorated_operator_class=_DecoratedSFTPSensorOperator,
+        decorated_operator_class=_DecoratedSFTPSensor,
         **kwargs,
     )

Reply via email to