---
source: crates/ruff_linter/src/rules/airflow/mod.rs
---
AIR302 [*] `airflow.hooks.dbapi.ConnectorProtocol` is moved into `common-sql` provider in Airflow 3.0;
 --> AIR302_common_sql.py:8:1
  |
6 | )
7 |
8 | ConnectorProtocol()
  | ^^^^^^^^^^^^^^^^^
9 | DbApiHook()
  |
help: Install `apache-airflow-providers-common-sql>=1.0.0` and use `ConnectorProtocol` from `airflow.providers.common.sql.hooks.sql` instead.
  |
3 | from airflow.hooks.dbapi import (
  -     ConnectorProtocol,
4 |     DbApiHook,
5 | )
6 + from airflow.providers.common.sql.hooks.sql import ConnectorProtocol
7 |
  |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.hooks.dbapi.DbApiHook` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:9:1
   |
 8 | ConnectorProtocol()
 9 | DbApiHook()
   | ^^^^^^^^^
10 |
11 | from airflow.hooks.dbapi_hook import DbApiHook
   |
help: Install `apache-airflow-providers-common-sql>=1.0.0` and use `DbApiHook` from `airflow.providers.common.sql.hooks.sql` instead.
  |
4 |     ConnectorProtocol,
  -     DbApiHook,
5 | )
6 + from airflow.providers.common.sql.hooks.sql import DbApiHook
7 |
  |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.hooks.dbapi_hook.DbApiHook` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:14:1
   |
12 | from airflow.operators.check_operator import SQLCheckOperator
13 |
14 | DbApiHook()
   | ^^^^^^^^^
15 | SQLCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.0.0` and use `DbApiHook` from `airflow.providers.common.sql.hooks.sql` instead.
   |
10 |
   - from airflow.hooks.dbapi_hook import DbApiHook
11 | from airflow.operators.check_operator import SQLCheckOperator
12 + from airflow.providers.common.sql.hooks.sql import DbApiHook
13 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.check_operator.SQLCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:15:1
   |
14 | DbApiHook()
15 | SQLCheckOperator()
   | ^^^^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
11 | from airflow.hooks.dbapi_hook import DbApiHook
   - from airflow.operators.check_operator import SQLCheckOperator
12 + from airflow.providers.common.sql.operators.sql import SQLCheckOperator
13 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.SQLCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:21:1
   |
19 | from airflow.operators.sql import SQLCheckOperator
20 |
21 | SQLCheckOperator()
   | ^^^^^^^^^^^^^^^^
22 | CheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
18 | from airflow.operators.check_operator import CheckOperator
   - from airflow.operators.sql import SQLCheckOperator
19 + from airflow.providers.common.sql.operators.sql import SQLCheckOperator
20 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.check_operator.CheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:22:1
   |
21 | SQLCheckOperator()
22 | CheckOperator()
   | ^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
19 | from airflow.operators.sql import SQLCheckOperator
20 + from airflow.providers.common.sql.operators.sql import SQLCheckOperator
21 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.druid_check_operator.CheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:27:1
   |
25 | from airflow.operators.druid_check_operator import CheckOperator
26 |
27 | CheckOperator()
   | ^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
25 | from airflow.operators.druid_check_operator import CheckOperator
26 + from airflow.providers.common.sql.operators.sql import SQLCheckOperator
27 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.presto_check_operator.CheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:32:1
   |
30 | from airflow.operators.presto_check_operator import CheckOperator
31 |
32 | CheckOperator()
   | ^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
30 | from airflow.operators.presto_check_operator import CheckOperator
31 + from airflow.providers.common.sql.operators.sql import SQLCheckOperator
32 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.druid_check_operator.DruidCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:42:1
   |
40 | from airflow.operators.presto_check_operator import PrestoCheckOperator
41 |
42 | DruidCheckOperator()
   | ^^^^^^^^^^^^^^^^^^
43 | PrestoCheckOperator()
44 | IntervalCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
40 | from airflow.operators.presto_check_operator import PrestoCheckOperator
41 + from airflow.providers.common.sql.operators.sql import SQLCheckOperator
42 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.presto_check_operator.PrestoCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:43:1
   |
42 | DruidCheckOperator()
43 | PrestoCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^
44 | IntervalCheckOperator()
45 | SQLIntervalCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
40 | from airflow.operators.presto_check_operator import PrestoCheckOperator
41 + from airflow.providers.common.sql.operators.sql import SQLCheckOperator
42 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.check_operator.IntervalCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:44:1
   |
42 | DruidCheckOperator()
43 | PrestoCheckOperator()
44 | IntervalCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^
45 | SQLIntervalCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLIntervalCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
36 |     IntervalCheckOperator,
   -     SQLIntervalCheckOperator,
37 | )
38 | from airflow.operators.druid_check_operator import DruidCheckOperator
39 | from airflow.operators.presto_check_operator import PrestoCheckOperator
40 + from airflow.providers.common.sql.operators.sql import SQLIntervalCheckOperator
41 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.check_operator.SQLIntervalCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:45:1
   |
43 | PrestoCheckOperator()
44 | IntervalCheckOperator()
45 | SQLIntervalCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLIntervalCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
36 |     IntervalCheckOperator,
   -     SQLIntervalCheckOperator,
37 | )
38 | from airflow.operators.druid_check_operator import DruidCheckOperator
39 | from airflow.operators.presto_check_operator import PrestoCheckOperator
40 + from airflow.providers.common.sql.operators.sql import SQLIntervalCheckOperator
41 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.presto_check_operator.IntervalCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:54:1
   |
52 | from airflow.operators.sql import SQLIntervalCheckOperator
53 |
54 | IntervalCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^
55 | SQLIntervalCheckOperator()
56 | PrestoIntervalCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLIntervalCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
52 | from airflow.operators.sql import SQLIntervalCheckOperator
53 + from airflow.providers.common.sql.operators.sql import SQLIntervalCheckOperator
54 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.SQLIntervalCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:55:1
   |
54 | IntervalCheckOperator()
55 | SQLIntervalCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^^^^
56 | PrestoIntervalCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLIntervalCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
51 | )
   - from airflow.operators.sql import SQLIntervalCheckOperator
52 + from airflow.providers.common.sql.operators.sql import SQLIntervalCheckOperator
53 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.presto_check_operator.PrestoIntervalCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:56:1
   |
54 | IntervalCheckOperator()
55 | SQLIntervalCheckOperator()
56 | PrestoIntervalCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLIntervalCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
52 | from airflow.operators.sql import SQLIntervalCheckOperator
53 + from airflow.providers.common.sql.operators.sql import SQLIntervalCheckOperator
54 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.check_operator.SQLThresholdCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:64:1
   |
62 | )
63 |
64 | SQLThresholdCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^^^^^
65 | ThresholdCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLThresholdCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
59 | from airflow.operators.check_operator import (
   -     SQLThresholdCheckOperator,
60 |     ThresholdCheckOperator,
61 | )
62 + from airflow.providers.common.sql.operators.sql import SQLThresholdCheckOperator
63 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.check_operator.ThresholdCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:65:1
   |
64 | SQLThresholdCheckOperator()
65 | ThresholdCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLThresholdCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
59 | from airflow.operators.check_operator import (
   -     SQLThresholdCheckOperator,
60 |     ThresholdCheckOperator,
61 | )
62 + from airflow.providers.common.sql.operators.sql import SQLThresholdCheckOperator
63 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.SQLThresholdCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:70:1
   |
68 | from airflow.operators.sql import SQLThresholdCheckOperator
69 |
70 | SQLThresholdCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLThresholdCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
67 |
   - from airflow.operators.sql import SQLThresholdCheckOperator
68 + from airflow.providers.common.sql.operators.sql import SQLThresholdCheckOperator
69 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.check_operator.SQLValueCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:78:1
   |
76 | )
77 |
78 | SQLValueCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^
79 | ValueCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLValueCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
73 | from airflow.operators.check_operator import (
   -     SQLValueCheckOperator,
74 |     ValueCheckOperator,
75 | )
76 + from airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
77 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.check_operator.ValueCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:79:1
   |
78 | SQLValueCheckOperator()
79 | ValueCheckOperator()
   | ^^^^^^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLValueCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
73 | from airflow.operators.check_operator import (
   -     SQLValueCheckOperator,
74 |     ValueCheckOperator,
75 | )
76 + from airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
77 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.SQLValueCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:88:1
   |
86 | from airflow.operators.sql import SQLValueCheckOperator
87 |
88 | SQLValueCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^
89 | ValueCheckOperator()
90 | PrestoValueCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLValueCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
85 | )
   - from airflow.operators.sql import SQLValueCheckOperator
86 + from airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
87 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.presto_check_operator.ValueCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:89:1
   |
88 | SQLValueCheckOperator()
89 | ValueCheckOperator()
   | ^^^^^^^^^^^^^^^^^^
90 | PrestoValueCheckOperator()
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLValueCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
86 | from airflow.operators.sql import SQLValueCheckOperator
87 + from airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
88 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.presto_check_operator.PrestoValueCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
  --> AIR302_common_sql.py:90:1
   |
88 | SQLValueCheckOperator()
89 | ValueCheckOperator()
90 | PrestoValueCheckOperator()
   | ^^^^^^^^^^^^^^^^^^^^^^^^
   |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLValueCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
   |
86 | from airflow.operators.sql import SQLValueCheckOperator
87 + from airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
88 |
   |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.BaseSQLOperator` is moved into `common-sql` provider in Airflow 3.0;
   --> AIR302_common_sql.py:102:1
    |
100 | )
101 |
102 | BaseSQLOperator()
    | ^^^^^^^^^^^^^^^
103 | BranchSQLOperator()
104 | SQLTableCheckOperator()
    |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `BaseSQLOperator` from `airflow.providers.common.sql.operators.sql` instead.
    |
93  | from airflow.operators.sql import (
    -     BaseSQLOperator,
94  |     BranchSQLOperator,
--------------------------------------------------------------------------------
99  | )
100 + from airflow.providers.common.sql.operators.sql import BaseSQLOperator
101 |
    |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.BranchSQLOperator` is moved into `common-sql` provider in Airflow 3.0;
   --> AIR302_common_sql.py:103:1
    |
102 | BaseSQLOperator()
103 | BranchSQLOperator()
    | ^^^^^^^^^^^^^^^^^
104 | SQLTableCheckOperator()
105 | SQLColumnCheckOperator()
    |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `BranchSQLOperator` from `airflow.providers.common.sql.operators.sql` instead.
    |
94  |     BaseSQLOperator,
    -     BranchSQLOperator,
95  |     SQLColumnCheckOperator,
--------------------------------------------------------------------------------
99  | )
100 + from airflow.providers.common.sql.operators.sql import BranchSQLOperator
101 |
    |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.SQLTableCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
   --> AIR302_common_sql.py:104:1
    |
102 | BaseSQLOperator()
103 | BranchSQLOperator()
104 | SQLTableCheckOperator()
    | ^^^^^^^^^^^^^^^^^^^^^
105 | SQLColumnCheckOperator()
106 | _convert_to_float_if_possible()
    |
help: Install `apache-airflow-providers-common-sql>=1.1.0` and use `SQLTableCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
    |
96  |     SQLColumnCheckOperator,
    -     SQLTableCheckOperator,
97  |     _convert_to_float_if_possible,
98  |     parse_boolean,
99  | )
100 + from airflow.providers.common.sql.operators.sql import SQLTableCheckOperator
101 |
    |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.SQLColumnCheckOperator` is moved into `common-sql` provider in Airflow 3.0;
   --> AIR302_common_sql.py:105:1
    |
103 | BranchSQLOperator()
104 | SQLTableCheckOperator()
105 | SQLColumnCheckOperator()
    | ^^^^^^^^^^^^^^^^^^^^^^
106 | _convert_to_float_if_possible()
107 | parse_boolean()
    |
help: Install `apache-airflow-providers-common-sql>=1.0.0` and use `SQLColumnCheckOperator` from `airflow.providers.common.sql.operators.sql` instead.
    |
95  |     BranchSQLOperator,
    -     SQLColumnCheckOperator,
96  |     SQLTableCheckOperator,
97  |     _convert_to_float_if_possible,
98  |     parse_boolean,
99  | )
100 + from airflow.providers.common.sql.operators.sql import SQLColumnCheckOperator
101 |
    |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql._convert_to_float_if_possible` is moved into `common-sql` provider in Airflow 3.0;
   --> AIR302_common_sql.py:106:1
    |
104 | SQLTableCheckOperator()
105 | SQLColumnCheckOperator()
106 | _convert_to_float_if_possible()
    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
107 | parse_boolean()
    |
help: Install `apache-airflow-providers-common-sql>=1.0.0` and use `_convert_to_float_if_possible` from `airflow.providers.common.sql.operators.sql` instead.
    |
97  |     SQLTableCheckOperator,
    -     _convert_to_float_if_possible,
98  |     parse_boolean,
99  | )
100 + from airflow.providers.common.sql.operators.sql import _convert_to_float_if_possible
101 |
    |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.operators.sql.parse_boolean` is moved into `common-sql` provider in Airflow 3.0;
   --> AIR302_common_sql.py:107:1
    |
105 | SQLColumnCheckOperator()
106 | _convert_to_float_if_possible()
107 | parse_boolean()
    | ^^^^^^^^^^^^^
    |
help: Install `apache-airflow-providers-common-sql>=1.0.0` and use `parse_boolean` from `airflow.providers.common.sql.operators.sql` instead.
    |
98  |     _convert_to_float_if_possible,
    -     parse_boolean,
99  | )
100 + from airflow.providers.common.sql.operators.sql import parse_boolean
101 |
    |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.sensors.sql.SqlSensor` is moved into `common-sql` provider in Airflow 3.0;
   --> AIR302_common_sql.py:112:1
    |
110 | from airflow.sensors.sql import SqlSensor
111 |
112 | SqlSensor()
    | ^^^^^^^^^
    |
help: Install `apache-airflow-providers-common-sql>=1.0.0` and use `SqlSensor` from `airflow.providers.common.sql.sensors.sql` instead.
    |
109 |
    - from airflow.sensors.sql import SqlSensor
110 + from airflow.providers.common.sql.sensors.sql import SqlSensor
111 |
    |
note: This is an unsafe fix and may change runtime behavior

AIR302 [*] `airflow.sensors.sql_sensor.SqlSensor` is moved into `common-sql` provider in Airflow 3.0;
   --> AIR302_common_sql.py:117:1
    |
115 | from airflow.sensors.sql_sensor import SqlSensor
116 |
117 | SqlSensor()
    | ^^^^^^^^^
    |
help: Install `apache-airflow-providers-common-sql>=1.0.0` and use `SqlSensor` from `airflow.providers.common.sql.sensors.sql` instead.
    |
114 |
    - from airflow.sensors.sql_sensor import SqlSensor
115 + from airflow.providers.common.sql.sensors.sql import SqlSensor
116 |
    |
note: This is an unsafe fix and may change runtime behavior
