Skip to content

Commit 0d649f9

Browse files
authored
Check that airflow module is seen for AIR001 (#14627)
1 parent 82c01aa commit 0d649f9

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

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

+6-1
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ use ruff_diagnostics::{Diagnostic, Violation};
22
use ruff_macros::{derive_message_formats, violation};
33
use ruff_python_ast as ast;
44
use ruff_python_ast::Expr;
5+
use ruff_python_semantic::Modules;
56
use ruff_text_size::Ranged;
67

78
use crate::checkers::ast::Checker;
@@ -49,6 +50,10 @@ pub(crate) fn variable_name_task_id(
4950
targets: &[Expr],
5051
value: &Expr,
5152
) -> Option<Diagnostic> {
53+
if !checker.semantic().seen_module(Modules::AIRFLOW) {
54+
return None;
55+
}
56+
5257
// If we have more than one target, we can't do anything.
5358
let [target] = targets else {
5459
return None;
@@ -69,7 +74,7 @@ pub(crate) fn variable_name_task_id(
6974
if !checker
7075
.semantic()
7176
.resolve_qualified_name(func)
72-
.is_some_and(|qualified_name| matches!(qualified_name.segments()[0], "airflow"))
77+
.is_some_and(|qualified_name| matches!(qualified_name.segments(), ["airflow", ..]))
7378
{
7479
return None;
7580
}

0 commit comments

Comments
 (0)