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,
)