Coverage for /pythoncovmergedfiles/medio/medio/src/airflow/build/lib/airflow/operators/__init__.py: 100%

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"""Operators.""" 

20from __future__ import annotations 

21 

22from airflow.utils.deprecation_tools import add_deprecated_classes 

23 

24__deprecated_classes = { 

25 'bash_operator': { 

26 'BashOperator': 'airflow.operators.bash.BashOperator', 

27 }, 

28 'branch_operator': { 

29 'BaseBranchOperator': 'airflow.operators.branch.BaseBranchOperator', 

30 }, 

31 'check_operator': { 

32 'SQLCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLCheckOperator', 

33 'SQLIntervalCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator', 

34 'SQLThresholdCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator', 

35 'SQLValueCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLValueCheckOperator', 

36 'CheckOperator': 'airflow.providers.common.sql.operators.sql.SQLCheckOperator', 

37 'IntervalCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator', 

38 'ThresholdCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator', 

39 'ValueCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLValueCheckOperator', 

40 }, 

41 'dagrun_operator': { 

42 'TriggerDagRunLink': 'airflow.operators.trigger_dagrun.TriggerDagRunLink', 

43 'TriggerDagRunOperator': 'airflow.operators.trigger_dagrun.TriggerDagRunOperator', 

44 }, 

45 'docker_operator': { 

46 'DockerOperator': 'airflow.providers.docker.operators.docker.DockerOperator', 

47 }, 

48 'druid_check_operator': { 

49 'DruidCheckOperator': 'airflow.providers.apache.druid.operators.druid_check.DruidCheckOperator', 

50 }, 

51 'dummy': { 

52 'EmptyOperator': 'airflow.operators.empty.EmptyOperator', 

53 'DummyOperator': 'airflow.operators.empty.EmptyOperator', 

54 }, 

55 'dummy_operator': { 

56 'EmptyOperator': 'airflow.operators.empty.EmptyOperator', 

57 'DummyOperator': 'airflow.operators.empty.EmptyOperator', 

58 }, 

59 'email_operator': { 

60 'EmailOperator': 'airflow.operators.email.EmailOperator', 

61 }, 

62 'gcs_to_s3': { 

63 'GCSToS3Operator': 'airflow.providers.amazon.aws.transfers.gcs_to_s3.GCSToS3Operator', 

64 }, 

65 'google_api_to_s3_transfer': { 

66 'GoogleApiToS3Operator': ( 

67 'airflow.providers.amazon.aws.transfers.google_api_to_s3.GoogleApiToS3Operator' 

68 ), 

69 'GoogleApiToS3Transfer': ( 

70 'airflow.providers.amazon.aws.transfers.google_api_to_s3.GoogleApiToS3Operator' 

71 ), 

72 }, 

73 'hive_operator': { 

74 'HiveOperator': 'airflow.providers.apache.hive.operators.hive.HiveOperator', 

75 }, 

76 'hive_stats_operator': { 

77 'HiveStatsCollectionOperator': ( 

78 'airflow.providers.apache.hive.operators.hive_stats.HiveStatsCollectionOperator' 

79 ), 

80 }, 

81 'hive_to_druid': { 

82 'HiveToDruidOperator': 'airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator', 

83 'HiveToDruidTransfer': 'airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator', 

84 }, 

85 'hive_to_mysql': { 

86 'HiveToMySqlOperator': 'airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator', 

87 'HiveToMySqlTransfer': 'airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator', 

88 }, 

89 'hive_to_samba_operator': { 

90 'HiveToSambaOperator': 'airflow.providers.apache.hive.transfers.hive_to_samba.HiveToSambaOperator', 

91 }, 

92 'http_operator': { 

93 'SimpleHttpOperator': 'airflow.providers.http.operators.http.SimpleHttpOperator', 

94 }, 

95 'jdbc_operator': { 

96 'JdbcOperator': 'airflow.providers.jdbc.operators.jdbc.JdbcOperator', 

97 }, 

98 'latest_only_operator': { 

99 'LatestOnlyOperator': 'airflow.operators.latest_only.LatestOnlyOperator', 

100 }, 

101 'mssql_operator': { 

102 'MsSqlOperator': 'airflow.providers.microsoft.mssql.operators.mssql.MsSqlOperator', 

103 }, 

104 'mssql_to_hive': { 

105 'MsSqlToHiveOperator': 'airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator', 

106 'MsSqlToHiveTransfer': 'airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator', 

107 }, 

108 'mysql_operator': { 

109 'MySqlOperator': 'airflow.providers.mysql.operators.mysql.MySqlOperator', 

110 }, 

111 'mysql_to_hive': { 

112 'MySqlToHiveOperator': 'airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator', 

113 'MySqlToHiveTransfer': 'airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator', 

114 }, 

115 'oracle_operator': { 

116 'OracleOperator': 'airflow.providers.oracle.operators.oracle.OracleOperator', 

117 }, 

118 'papermill_operator': { 

119 'PapermillOperator': 'airflow.providers.papermill.operators.papermill.PapermillOperator', 

120 }, 

121 'pig_operator': { 

122 'PigOperator': 'airflow.providers.apache.pig.operators.pig.PigOperator', 

123 }, 

124 'postgres_operator': { 

125 'Mapping': 'airflow.providers.postgres.operators.postgres.Mapping', 

126 'PostgresOperator': 'airflow.providers.postgres.operators.postgres.PostgresOperator', 

127 }, 

128 'presto_check_operator': { 

129 'SQLCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLCheckOperator', 

130 'SQLIntervalCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator', 

131 'SQLValueCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLValueCheckOperator', 

132 'PrestoCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLCheckOperator', 

133 'PrestoIntervalCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator', 

134 'PrestoValueCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLValueCheckOperator', 

135 }, 

136 'presto_to_mysql': { 

137 'PrestoToMySqlOperator': 'airflow.providers.mysql.transfers.presto_to_mysql.PrestoToMySqlOperator', 

138 'PrestoToMySqlTransfer': 'airflow.providers.mysql.transfers.presto_to_mysql.PrestoToMySqlOperator', 

139 }, 

140 'python_operator': { 

141 'BranchPythonOperator': 'airflow.operators.python.BranchPythonOperator', 

142 'PythonOperator': 'airflow.operators.python.PythonOperator', 

143 'PythonVirtualenvOperator': 'airflow.operators.python.PythonVirtualenvOperator', 

144 'ShortCircuitOperator': 'airflow.operators.python.ShortCircuitOperator', 

145 }, 

146 'redshift_to_s3_operator': { 

147 'RedshiftToS3Operator': 'airflow.providers.amazon.aws.transfers.redshift_to_s3.RedshiftToS3Operator', 

148 'RedshiftToS3Transfer': 'airflow.providers.amazon.aws.transfers.redshift_to_s3.RedshiftToS3Operator', 

149 }, 

150 's3_file_transform_operator': { 

151 'S3FileTransformOperator': ( 

152 'airflow.providers.amazon.aws.operators.s3_file_transform.S3FileTransformOperator' 

153 ), 

154 }, 

155 's3_to_hive_operator': { 

156 'S3ToHiveOperator': 'airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator', 

157 'S3ToHiveTransfer': 'airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator', 

158 }, 

159 's3_to_redshift_operator': { 

160 'S3ToRedshiftOperator': 'airflow.providers.amazon.aws.transfers.s3_to_redshift.S3ToRedshiftOperator', 

161 'S3ToRedshiftTransfer': 'airflow.providers.amazon.aws.transfers.s3_to_redshift.S3ToRedshiftOperator', 

162 }, 

163 'slack_operator': { 

164 'SlackAPIOperator': 'airflow.providers.slack.operators.slack.SlackAPIOperator', 

165 'SlackAPIPostOperator': 'airflow.providers.slack.operators.slack.SlackAPIPostOperator', 

166 }, 

167 'sql': { 

168 'BaseSQLOperator': 'airflow.providers.common.sql.operators.sql.BaseSQLOperator', 

169 'BranchSQLOperator': 'airflow.providers.common.sql.operators.sql.BranchSQLOperator', 

170 'SQLCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLCheckOperator', 

171 'SQLColumnCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator', 

172 'SQLIntervalCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator', 

173 'SQLTableCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLTableCheckOperator', 

174 'SQLThresholdCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator', 

175 'SQLValueCheckOperator': 'airflow.providers.common.sql.operators.sql.SQLValueCheckOperator', 

176 '_convert_to_float_if_possible': ( 

177 'airflow.providers.common.sql.operators.sql._convert_to_float_if_possible' 

178 ), 

179 'parse_boolean': 'airflow.providers.common.sql.operators.sql.parse_boolean', 

180 }, 

181 'sql_branch_operator': { 

182 'BranchSQLOperator': 'airflow.providers.common.sql.operators.sql.BranchSQLOperator', 

183 'BranchSqlOperator': 'airflow.providers.common.sql.operators.sql.BranchSQLOperator', 

184 }, 

185 'sqlite_operator': { 

186 'SqliteOperator': 'airflow.providers.sqlite.operators.sqlite.SqliteOperator', 

187 }, 

188 'subdag_operator': { 

189 'SkippedStatePropagationOptions': 'airflow.operators.subdag.SkippedStatePropagationOptions', 

190 'SubDagOperator': 'airflow.operators.subdag.SubDagOperator', 

191 }, 

192} 

193 

194add_deprecated_classes(__deprecated_classes, __name__)