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

5 statements  

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. 

21 

22:sphinx-autoapi-skip: 

23""" 

24 

25from __future__ import annotations 

26 

27from airflow.utils.deprecation_tools import add_deprecated_classes 

28 

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} 

198 

199add_deprecated_classes(__deprecated_classes, __name__)