Skip to content

Commit 102698e

Browse files
committed
fix(AIR302): fix wrongly categorized airflow.sensors.external_task_sensor.ExternalTaskSensorLink
1 parent 188be16 commit 102698e

File tree

2 files changed

+9
-9
lines changed

2 files changed

+9
-9
lines changed

crates/ruff_linter/src/rules/airflow/rules/moved_to_provider_in_3.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1169,7 +1169,7 @@ fn check_names_moved_to_provider(checker: &Checker, expr: &Expr, ranged: TextRan
11691169
[
11701170
"airflow",
11711171
"sensors",
1172-
"external_task",
1172+
"external_task" | "external_task_sensor",
11731173
"ExternalTaskSensorLink",
11741174
] => ProviderReplacement::AutoImport {
11751175
module: "airflow.providers.standard.sensors.external_task",
@@ -1181,7 +1181,7 @@ fn check_names_moved_to_provider(checker: &Checker, expr: &Expr, ranged: TextRan
11811181
"airflow",
11821182
"sensors",
11831183
"external_task_sensor",
1184-
rest @ ("ExternalTaskMarker" | "ExternalTaskSensor" | "ExternalTaskSensorLink"),
1184+
rest @ ("ExternalTaskMarker" | "ExternalTaskSensor"),
11851185
] => ProviderReplacement::SourceModuleMovedToProvider {
11861186
module: "airflow.providers.standard.sensors.external_task",
11871187
name: (*rest).to_string(),

crates/ruff_linter/src/rules/airflow/snapshots/ruff_linter__rules__airflow__tests__AIR302_AIR302_standard.py.snap

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -478,13 +478,13 @@ AIR302_standard.py:78:1: AIR302 [*] `airflow.sensors.external_task_sensor.Extern
478478
78 | ExternalTaskSensorLink()
479479
| ^^^^^^^^^^^^^^^^^^^^^^ AIR302
480480
|
481-
= help: Install `apache-airflow-providers-standard>=0.0.3` and use `ExternalTaskSensorLink` from `airflow.providers.standard.sensors.external_task` instead.
481+
= help: Install `apache-airflow-providers-standard>=0.0.3` and use `ExternalDagLink` from `airflow.providers.standard.sensors.external_task` instead.
482482

483-
Unsafe fix
484-
73 73 |
483+
Safe fix
485484
74 74 | EmptyOperator()
486485
75 75 |
487-
76 |-from airflow.sensors.external_task_sensor import ExternalTaskSensorLink
488-
76 |+from airflow.providers.standard.sensors.external_task import ExternalTaskSensorLink
489-
77 77 |
490-
78 78 | ExternalTaskSensorLink()
486+
76 76 | from airflow.sensors.external_task_sensor import ExternalTaskSensorLink
487+
77 |+from airflow.providers.standard.sensors.external_task import ExternalDagLink
488+
77 78 |
489+
78 |-ExternalTaskSensorLink()
490+
79 |+ExternalDagLink()

0 commit comments

Comments
 (0)