Remove dag keyword from task decorator

feluelle · Apr 21, 2022 · af167cd · af167cd
1 parent f86e7b2
commit af167cd
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/airflint/rules/dag.py b/airflint/rules/dag.py
@@ -69,7 +69,9 @@ def match(self, node):
                     ast.Call(
                         func=ast.Name(id="dag", ctx=ast.Load()),
                         args=[],
-                        keywords=DAG.keywords,
+                        keywords=[
+                            keyword for keyword in DAG.keywords if keyword.arg != "dag"
+                        ],
                     ),
                 ],
                 lineno=node.lineno,