Coverage for /pythoncovmergedfiles/medio/medio/src/airflow/airflow/operators/__init__.py: 100%
Shortcuts on this page
r m x toggle line displays
j k next/prev highlighted chunk
0 (zero) top of page
1 (one) first highlighted chunk
Shortcuts on this page
r m x toggle line displays
j k next/prev highlighted chunk
0 (zero) top of page
1 (one) first highlighted chunk
1#
2# Licensed to the Apache Software Foundation (ASF) under one
3# or more contributor license agreements. See the NOTICE file
4# distributed with this work for additional information
5# regarding copyright ownership. The ASF licenses this file
6# to you under the Apache License, Version 2.0 (the
7# "License"); you may not use this file except in compliance
8# with the License. You may obtain a copy of the License at
9#
10# http://www.apache.org/licenses/LICENSE-2.0
11#
12# Unless required by applicable law or agreed to in writing,
13# software distributed under the License is distributed on an
14# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15# KIND, either express or implied. See the License for the
16# specific language governing permissions and limitations
17# under the License.
18# fmt: off
19"""
20Operators.
22:sphinx-autoapi-skip:
23"""
25from __future__ import annotations
27from airflow.utils.deprecation_tools import add_deprecated_classes
29__deprecated_classes = {
30 "bash_operator": {
31 "BashOperator": "airflow.operators.bash.BashOperator",
32 },
33 "branch_operator": {
34 "BaseBranchOperator": "airflow.operators.branch.BaseBranchOperator",
35 },
36 "check_operator": {
37 "SQLCheckOperator": "airflow.providers.common.sql.operators.sql.SQLCheckOperator",
38 "SQLIntervalCheckOperator": "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator",
39 "SQLThresholdCheckOperator": "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator",
40 "SQLValueCheckOperator": "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator",
41 "CheckOperator": "airflow.providers.common.sql.operators.sql.SQLCheckOperator",
42 "IntervalCheckOperator": "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator",
43 "ThresholdCheckOperator": "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator",
44 "ValueCheckOperator": "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator",
45 },
46 "dagrun_operator": {
47 "TriggerDagRunLink": "airflow.operators.trigger_dagrun.TriggerDagRunLink",
48 "TriggerDagRunOperator": "airflow.operators.trigger_dagrun.TriggerDagRunOperator",
49 },
50 "docker_operator": {
51 "DockerOperator": "airflow.providers.docker.operators.docker.DockerOperator",
52 },
53 "druid_check_operator": {
54 "DruidCheckOperator": "airflow.providers.apache.druid.operators.druid_check.DruidCheckOperator",
55 },
56 "dummy": {
57 "EmptyOperator": "airflow.operators.empty.EmptyOperator",
58 "DummyOperator": "airflow.operators.empty.EmptyOperator",
59 },
60 "dummy_operator": {
61 "EmptyOperator": "airflow.operators.empty.EmptyOperator",
62 "DummyOperator": "airflow.operators.empty.EmptyOperator",
63 },
64 "email_operator": {
65 "EmailOperator": "airflow.operators.email.EmailOperator",
66 },
67 "gcs_to_s3": {
68 "GCSToS3Operator": "airflow.providers.amazon.aws.transfers.gcs_to_s3.GCSToS3Operator",
69 },
70 "google_api_to_s3_transfer": {
71 "GoogleApiToS3Operator": (
72 "airflow.providers.amazon.aws.transfers.google_api_to_s3.GoogleApiToS3Operator"
73 ),
74 "GoogleApiToS3Transfer": (
75 "airflow.providers.amazon.aws.transfers.google_api_to_s3.GoogleApiToS3Operator"
76 ),
77 },
78 "hive_operator": {
79 "HiveOperator": "airflow.providers.apache.hive.operators.hive.HiveOperator",
80 },
81 "hive_stats_operator": {
82 "HiveStatsCollectionOperator": (
83 "airflow.providers.apache.hive.operators.hive_stats.HiveStatsCollectionOperator"
84 ),
85 },
86 "hive_to_druid": {
87 "HiveToDruidOperator": "airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator",
88 "HiveToDruidTransfer": "airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator",
89 },
90 "hive_to_mysql": {
91 "HiveToMySqlOperator": "airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator",
92 "HiveToMySqlTransfer": "airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator",
93 },
94 "hive_to_samba_operator": {
95 "HiveToSambaOperator": "airflow.providers.apache.hive.transfers.hive_to_samba.HiveToSambaOperator",
96 },
97 "http_operator": {
98 "SimpleHttpOperator": "airflow.providers.http.operators.http.SimpleHttpOperator",
99 },
100 "jdbc_operator": {
101 "JdbcOperator": "airflow.providers.jdbc.operators.jdbc.JdbcOperator",
102 },
103 "latest_only_operator": {
104 "LatestOnlyOperator": "airflow.operators.latest_only.LatestOnlyOperator",
105 },
106 "mssql_operator": {
107 "MsSqlOperator": "airflow.providers.microsoft.mssql.operators.mssql.MsSqlOperator",
108 },
109 "mssql_to_hive": {
110 "MsSqlToHiveOperator": "airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator",
111 "MsSqlToHiveTransfer": "airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator",
112 },
113 "mysql_operator": {
114 "MySqlOperator": "airflow.providers.mysql.operators.mysql.MySqlOperator",
115 },
116 "mysql_to_hive": {
117 "MySqlToHiveOperator": "airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator",
118 "MySqlToHiveTransfer": "airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator",
119 },
120 "oracle_operator": {
121 "OracleOperator": "airflow.providers.oracle.operators.oracle.OracleOperator",
122 },
123 "papermill_operator": {
124 "PapermillOperator": "airflow.providers.papermill.operators.papermill.PapermillOperator",
125 },
126 "pig_operator": {
127 "PigOperator": "airflow.providers.apache.pig.operators.pig.PigOperator",
128 },
129 "postgres_operator": {
130 "Mapping": "airflow.providers.postgres.operators.postgres.Mapping",
131 "PostgresOperator": "airflow.providers.postgres.operators.postgres.PostgresOperator",
132 },
133 "presto_check_operator": {
134 "SQLCheckOperator": "airflow.providers.common.sql.operators.sql.SQLCheckOperator",
135 "SQLIntervalCheckOperator": "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator",
136 "SQLValueCheckOperator": "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator",
137 "PrestoCheckOperator": "airflow.providers.common.sql.operators.sql.SQLCheckOperator",
138 "PrestoIntervalCheckOperator": "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator",
139 "PrestoValueCheckOperator": "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator",
140 },
141 "presto_to_mysql": {
142 "PrestoToMySqlOperator": "airflow.providers.mysql.transfers.presto_to_mysql.PrestoToMySqlOperator",
143 "PrestoToMySqlTransfer": "airflow.providers.mysql.transfers.presto_to_mysql.PrestoToMySqlOperator",
144 },
145 "python_operator": {
146 "BranchPythonOperator": "airflow.operators.python.BranchPythonOperator",
147 "PythonOperator": "airflow.operators.python.PythonOperator",
148 "PythonVirtualenvOperator": "airflow.operators.python.PythonVirtualenvOperator",
149 "ShortCircuitOperator": "airflow.operators.python.ShortCircuitOperator",
150 },
151 "redshift_to_s3_operator": {
152 "RedshiftToS3Operator": "airflow.providers.amazon.aws.transfers.redshift_to_s3.RedshiftToS3Operator",
153 "RedshiftToS3Transfer": "airflow.providers.amazon.aws.transfers.redshift_to_s3.RedshiftToS3Operator",
154 },
155 "s3_file_transform_operator": {
156 "S3FileTransformOperator": (
157 "airflow.providers.amazon.aws.operators.s3_file_transform.S3FileTransformOperator"
158 ),
159 },
160 "s3_to_hive_operator": {
161 "S3ToHiveOperator": "airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator",
162 "S3ToHiveTransfer": "airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator",
163 },
164 "s3_to_redshift_operator": {
165 "S3ToRedshiftOperator": "airflow.providers.amazon.aws.transfers.s3_to_redshift.S3ToRedshiftOperator",
166 "S3ToRedshiftTransfer": "airflow.providers.amazon.aws.transfers.s3_to_redshift.S3ToRedshiftOperator",
167 },
168 "slack_operator": {
169 "SlackAPIOperator": "airflow.providers.slack.operators.slack.SlackAPIOperator",
170 "SlackAPIPostOperator": "airflow.providers.slack.operators.slack.SlackAPIPostOperator",
171 },
172 "sql": {
173 "BaseSQLOperator": "airflow.providers.common.sql.operators.sql.BaseSQLOperator",
174 "BranchSQLOperator": "airflow.providers.common.sql.operators.sql.BranchSQLOperator",
175 "SQLCheckOperator": "airflow.providers.common.sql.operators.sql.SQLCheckOperator",
176 "SQLColumnCheckOperator": "airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator",
177 "SQLIntervalCheckOperator": "airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator",
178 "SQLTableCheckOperator": "airflow.providers.common.sql.operators.sql.SQLTableCheckOperator",
179 "SQLThresholdCheckOperator": "airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator",
180 "SQLValueCheckOperator": "airflow.providers.common.sql.operators.sql.SQLValueCheckOperator",
181 "_convert_to_float_if_possible": (
182 "airflow.providers.common.sql.operators.sql._convert_to_float_if_possible"
183 ),
184 "parse_boolean": "airflow.providers.common.sql.operators.sql.parse_boolean",
185 },
186 "sql_branch_operator": {
187 "BranchSQLOperator": "airflow.providers.common.sql.operators.sql.BranchSQLOperator",
188 "BranchSqlOperator": "airflow.providers.common.sql.operators.sql.BranchSQLOperator",
189 },
190 "sqlite_operator": {
191 "SqliteOperator": "airflow.providers.sqlite.operators.sqlite.SqliteOperator",
192 },
193 "subdag_operator": {
194 "SkippedStatePropagationOptions": "airflow.operators.subdag.SkippedStatePropagationOptions",
195 "SubDagOperator": "airflow.operators.subdag.SubDagOperator",
196 },
197}
199add_deprecated_classes(__deprecated_classes, __name__)