Lee-W commented on issue #49598:
URL: https://github.com/apache/airflow/issues/49598#issuecomment-2862747980
The latest ruff rules (after the latest PR merged) (WIP)
<details>
<summary> AIR302 </summary>
# apache-airflow-providers-amazon
from airflow.hooks.S3_hook import S3Hook # → from
airflow.providers.amazon.aws.hooks.s3 import S3Hook
from airflow.hooks.S3_hook import provide_bucket_name # → from
airflow.providers.amazon.aws.hooks.s3 import provide_bucket_name
from airflow.operators.gcs_to_s3 import GCSToS3Operator # → from
airflow.providers.amazon.aws.transfers.gcs_to_s3 import GCSToS3Operator
from airflow.operators.google_api_to_s3_transfer import
GoogleApiToS3Operator # → from
airflow.providers.amazon.aws.transfers.google_api_to_s3 import
GoogleApiToS3Operator
from airflow.operators.google_api_to_s3_transfer import
GoogleApiToS3Transfer # → from
airflow.providers.amazon.aws.transfers.google_api_to_s3 import
GoogleApiToS3Operator
from airflow.operators.redshift_to_s3_operator import RedshiftToS3Operator
# → from airflow.providers.amazon.aws.transfers.redshift_to_s3 import
RedshiftToS3Operator
from airflow.operators.redshift_to_s3_operator import RedshiftToS3Transfer #
→ from airflow.providers.amazon.aws.transfers.redshift_to_s3 import
RedshiftToS3Operator
from airflow.operators.s3_file_transform_operator import
S3FileTransformOperator # → from airflow.providers.amazon.aws.operators.s3
import S3FileTransformOperator
from airflow.operators.s3_to_redshift_operator import S3ToRedshiftOperator #
→ from airflow.providers.amazon.aws.transfers.s3_to_redshift import
S3ToRedshiftOperator
from airflow.operators.s3_to_redshift_operator import S3ToRedshiftTransfer #
→ from airflow.providers.amazon.aws.transfers.s3_to_redshift import
S3ToRedshiftOperator
from airflow.sensors.s3_key_sensor import S3KeySensor # → from
airflow.providers.amazon.aws.sensors.s3 import S3KeySensor
# apache-airflow-providers-celery
from airflow.config_templates.default_celery import DEFAULT_CELERY_CONFIG #
→ from airflow.providers.celery.executors.default_celery import
DEFAULT_CELERY_CONFIG
from airflow.executors.celery_executor import app # → from
airflow.providers.celery.executors.celery_executor_utils import app
from airflow.executors.celery_executor import CeleryExecutor # → from
airflow.providers.celery.executors.celery_executor import CeleryExecutor
from airflow.executors.celery_kubernetes_executor import
CeleryKubernetesExecutor # → from
airflow.providers.celery.executors.celery_kubernetes_executor import
CeleryKubernetesExecutor
# apache-airflow-providers-common-sql
from airflow.hooks.dbapi import ConnectorProtocol # → from
airflow.providers.common.sql.hooks.sql import ConnectorProtocol
from airflow.hooks.dbapi import DbApiHook # → from
airflow.providers.common.sql.hooks.sql import DbApiHook
from airflow.hooks.dbapi_hook import DbApiHook # → from
airflow.providers.common.sql.hooks.sql import DbApiHook
from airflow.operators.check_operator import SQLCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLCheckOperator
from airflow.operators.sql import SQLCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLCheckOperator
from airflow.operators.check_operator import CheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLCheckOperator
from airflow.operators.druid_check_operator import CheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLCheckOperator
from airflow.operators.presto_check_operator import CheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLCheckOperator
from airflow.operators.druid_check_operator import DruidCheckOperator # →
from airflow.providers.common.sql.operators.sql import SQLCheckOperator
from airflow.operators.presto_check_operator import PrestoCheckOperator # →
from airflow.providers.common.sql.operators.sql import SQLCheckOperator
from airflow.operators.check_operator import IntervalCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLIntervalCheckOperator
from airflow.operators.check_operator import SQLIntervalCheckOperator # →
from airflow.providers.common.sql.operators.sql import SQLIntervalCheckOperator
from airflow.operators.presto_check_operator import IntervalCheckOperator #
→ from airflow.providers.common.sql.operators.sql import
SQLIntervalCheckOperator
from airflow.operators.presto_check_operator import
PrestoIntervalCheckOperator # → from airflow.providers.common.sql.operators.sql
import SQLIntervalCheckOperator
from airflow.operators.sql import SQLIntervalCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLIntervalCheckOperator
from airflow.operators.check_operator import SQLThresholdCheckOperator # →
from airflow.providers.common.sql.operators.sql import SQLThresholdCheckOperator
from airflow.operators.check_operator import ThresholdCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLThresholdCheckOperator
from airflow.operators.sql import SQLThresholdCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLThresholdCheckOperator
from airflow.operators.check_operator import SQLValueCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
from airflow.operators.check_operator import ValueCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
from airflow.operators.presto_check_operator import PrestoValueCheckOperator
# → from airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
from airflow.operators.presto_check_operator import ValueCheckOperator # →
from airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
from airflow.operators.sql import SQLValueCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLValueCheckOperator
from airflow.operators.sql import BaseSQLOperator # → from
airflow.providers.common.sql.operators.sql import BaseSQLOperator
from airflow.operators.sql import BranchSQLOperator # → from
airflow.providers.common.sql.operators.sql import BranchSQLOperator
from airflow.operators.sql import SQLTableCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLTableCheckOperator
from airflow.operators.sql import SQLColumnCheckOperator # → from
airflow.providers.common.sql.operators.sql import SQLColumnCheckOperator
from airflow.operators.sql import _convert_to_float_if_possible # → from
airflow.providers.common.sql.operators.sql import _convert_to_float_if_possible
from airflow.operators.sql import parse_boolean # → from
airflow.providers.common.sql.operators.sql import parse_boolean
,
from airflow.sensors.sql import SqlSensor # → from
airflow.providers.common.sql.sensors.sql import SqlSensor
from airflow.sensors.sql_sensor import SqlSensor # → from
airflow.providers.common.sql.sensors.sql import SqlSensor
from airflow.operators.jdbc_operator import JdbcOperator # → from
airflow.providers.common.sql.operators.sql import SQLExecuteQueryOperator
from airflow.operators.mssql_operator import MsSqlOperator # → from
airflow.providers.common.sql.operators.sql import SQLExecuteQueryOperator
from airflow.operators.mysql_operator import MySqlOperator # → from
airflow.providers.common.sql.operators.sql import SQLExecuteQueryOperator
from airflow.operators.oracle_operator import OracleOperator # → from
airflow.providers.common.sql.operators.sql import SQLExecuteQueryOperator
from airflow.operators.postgres_operator import PostgresOperator # → from
airflow.providers.common.sql.operators.sql import SQLExecuteQueryOperator
from airflow.operators.sqlite_operator import SqliteOperator # → from
airflow.providers.common.sql.operators.sql import SQLExecuteQueryOperator
# apache-airflow-providers-daskexecutor
from airflow.executors.dask_executor import DaskExecutor # → from
airflow.providers.daskexecutor.executors.dask_executor import DaskExecutor
# apache-airflow-providers-docker
from airflow.hooks.docker_hook import DockerHook # → from
airflow.providers.docker.hooks.docker import DockerHook
from airflow.operators.docker_operator import DockerOperator # → from
airflow.providers.docker.operators.docker import DockerOperator
# apache-airflow-providers-apache-druid
from airflow.hooks.druid_hook import DruidDbApiHook # → from
airflow.providers.apache.druid.hooks.druid import DruidDbApiHook
from airflow.hooks.druid_hook import DruidHook # → from
airflow.providers.apache.druid.hooks.druid import DruidHook
from airflow.operators.hive_to_druid import HiveToDruidOperator # → from
airflow.providers.apache.druid.transfers.hive_to_druid import
HiveToDruidOperator
from airflow.operators.hive_to_druid import HiveToDruidTransfer # → from
airflow.providers.apache.druid.transfers.hive_to_druid import
HiveToDruidOperator
# apache-airflow-providers-fab
from airflow.api.auth.backend.basic_auth import CLIENT_AUTH # → from
airflow.providers.fab.auth_manager.api.auth.backend.basic_auth import
CLIENT_AUTH
from airflow.api.auth.backend.basic_auth import init_app # → from
airflow.providers.fab.auth_manager.api.auth.backend.basic_auth import init_app
from airflow.api.auth.backend.basic_auth import auth_current_user # → from
airflow.providers.fab.auth_manager.api.auth.backend.basic_auth import
auth_current_user
from airflow.api.auth.backend.basic_auth import requires_authentication # →
from airflow.providers.fab.auth_manager.api.auth.backend.basic_auth import
requires_authentication
from airflow.api.auth.backend.kerberos_auth import log # → from
airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import log
from airflow.api.auth.backend.kerberos_auth import CLIENT_AUTH # → from
airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
CLIENT_AUTH
from airflow.api.auth.backend.kerberos_auth import find_user # → from
airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
find_user
from airflow.api.auth.backend.kerberos_auth import init_app # → from
airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
init_app
from airflow.api.auth.backend.kerberos_auth import requires_authentication #
→ from airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
requires_authentication
from airflow.auth.managers.fab.api.auth.backend.kerberos_auth import log # →
from airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
log
from airflow.auth.managers.fab.api.auth.backend.kerberos_auth import
CLIENT_AUTH # → from
airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
CLIENT_AUTH
from airflow.auth.managers.fab.api.auth.backend.kerberos_auth import
find_user # → from
airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
find_user
from airflow.auth.managers.fab.api.auth.backend.kerberos_auth import
init_app # → from
airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
init_app
from airflow.auth.managers.fab.api.auth.backend.kerberos_auth import
requires_authentication # → from
airflow.providers.fab.auth_manager.api.auth.backend.kerberos_auth import
requires_authentication
from airflow.auth.managers.fab.fab_auth_manager import FabAuthManager # →
from airflow.providers.fab.auth_manager.fab_auth_manager import FabAuthManager
from airflow.auth.managers.fab.security_manager.override import
MAX_NUM_DATABASE_USER_SESSIONS # → from
airflow.providers.fab.auth_manager.security_manager.override import
MAX_NUM_DATABASE_USER_SESSIONS
from airflow.auth.managers.fab.security_manager.override import
FabAirflowSecurityManagerOverride # → from
airflow.providers.fab.auth_manager.security_manager.override import
FabAirflowSecurityManagerOverride
from airflow.www.security import FabAirflowSecurityManagerOverride # → from
airflow.providers.fab.auth_manager.security_manager.override import
FabAirflowSecurityManagerOverride
# apache-airflow-providers-apache-hdfs
from airflow.hooks.webhdfs_hook import WebHDFSHook# → from
airflow.providers.apache.hdfs.hooks.webhdfs import WebHDFSHook
from airflow.sensors.web_hdfs_sensor import WebHdfsSensor # → from
airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor
# apache-airflow-providers-apache-hive
from airflow.hooks.hive_hooks import HiveCliHook # → from
airflow.providers.apache.hive.hooks.hive import HiveCliHook
from airflow.hooks.hive_hooks import HiveMetastoreHook # → from
airflow.providers.apache.hive.hooks.hive import HiveMetastoreHook
from airflow.hooks.hive_hooks import HiveServer2Hook # → from
airflow.providers.apache.hive.hooks.hive import HiveServer2Hook
from airflow.hooks.hive_hooks import HIVE_QUEUE_PRIORITIES # → from
airflow.providers.apache.hive.hooks.hive import HIVE_QUEUE_PRIORITIES
from airflow.macros.hive import closest_ds_partition # → from
airflow.providers.apache.hive.macros.hive import closest_ds_partition
from airflow.macros.hive import max_partition # → from
airflow.providers.apache.hive.macros.hive import max_partition
from airflow.operators.hive_operator import HiveOperator # → from
airflow.providers.apache.hive.operators.hive import HiveOperator
from airflow.operators.hive_stats_operator import
HiveStatsCollectionOperator # → from
airflow.providers.apache.hive.operators.hive_stats import
HiveStatsCollectionOperator
from airflow.operators.hive_to_mysql import HiveToMySqlOperator # → from
airflow.providers.apache.hive.transfers.hive_to_mysql import HiveToMySqlOperator
from airflow.operators.hive_to_mysql import HiveToMySqlTransfer # → from
airflow.providers.apache.hive.transfers.hive_to_mysql import HiveToMySqlOperator
from airflow.operators.hive_to_samba_operator import HiveToSambaOperator # →
from airflow.providers.apache.hive.transfers.hive_to_samba import
HiveToSambaOperator
from airflow.operators.mssql_to_hive import MsSqlToHiveOperator # → from
airflow.providers.apache.hive.transfers.mssql_to_hive import MsSqlToHiveOperator
from airflow.operators.mssql_to_hive import MsSqlToHiveTransfer # → from
airflow.providers.apache.hive.transfers.mssql_to_hive import MsSqlToHiveOperator
from airflow.operators.mysql_to_hive import MySqlToHiveOperator # → from
airflow.providers.apache.hive.transfers.mysql_to_hive import MySqlToHiveOperator
from airflow.operators.mysql_to_hive import MySqlToHiveTransfer # → from
airflow.providers.apache.hive.transfers.mysql_to_hive import MySqlToHiveOperator
from airflow.operators.s3_to_hive_operator import S3ToHiveOperator # → from
airflow.providers.apache.hive.transfers.s3_to_hive import S3ToHiveOperator
from airflow.operators.s3_to_hive_operator import S3ToHiveTransfer # → from
airflow.providers.apache.hive.transfers.s3_to_hive import S3ToHiveOperator
from airflow.sensors.hive_partition_sensor import HivePartitionSensor # →
from airflow.providers.apache.hive.sensors.hive_partition import
HivePartitionSensor
from airflow.sensors.metastore_partition_sensor import
MetastorePartitionSensor # → from
airflow.providers.apache.hive.sensors.metastore_partition import
MetastorePartitionSensor
from airflow.sensors.named_hive_partition_sensor import
NamedHivePartitionSensor # → from
airflow.providers.apache.hive.sensors.named_hive_partition import
NamedHivePartitionSensor
# apache-airflow-providers-http
from airflow.hooks.http_hook import HttpHook # → from
airflow.providers.http.hooks.http import HttpHook
from airflow.operators.http_operator import SimpleHttpOperator # → from
airflow.providers.http.operators.http import HttpOperator
from airflow.sensors.http_sensor import HttpSensor # → from
airflow.providers.http.sensors.http import HttpSensor
# apache-airflow-providers-jdbc
from airflow.hooks.jdbc_hook import JdbcHook # → from
airflow.providers.jdbc.hooks.jdbc import JdbcHook
from airflow.hooks.jdbc_hook import jaydebeapi # → from
airflow.providers.jdbc.hooks.jdbc import jaydebeapi
# apache-airflow-providers-cncf-kubernetes
from airflow.executors.kubernetes_executor_types import ALL_NAMESPACES # →
from airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types
import ALL_NAMESPACES
from airflow.executors.kubernetes_executor_types import
POD_EXECUTOR_DONE_KEY # → from
airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types import
POD_EXECUTOR_DONE_KEY
from airflow.kubernetes.k8s_model import K8SModel # → from
airflow.providers.cncf.kubernetes.k8s_model import K8SModel
from airflow.kubernetes.k8s_model import append_to_pod # → from
airflow.providers.cncf.kubernetes.k8s_model import append_to_pod
from airflow.kubernetes.kube_client import _disable_verify_ssl # → from
airflow.providers.cncf.kubernetes.kube_client import _disable_verify_ssl
from airflow.kubernetes.kube_client import _enable_tcp_keepalive # → from
airflow.providers.cncf.kubernetes.kube_client import _enable_tcp_keepalive
from airflow.kubernetes.kube_client import get_kube_client # → from
airflow.providers.cncf.kubernetes.kube_client import get_kube_client
from airflow.kubernetes.kubernetes_helper_functions import add_pod_suffix #
→ from airflow.providers.cncf.kubernetes.kubernetes_helper_functions import
add_unique_suffix
from airflow.kubernetes.kubernetes_helper_functions import create_pod_id # →
from airflow.providers.cncf.kubernetes.kubernetes_helper_functions import
create_unique_id
from airflow.kubernetes.kubernetes_helper_functions import
annotations_for_logging_task_metadata # → from
airflow.providers.cncf.kubernetes.kubernetes_helper_functions import
annotations_for_logging_task_metadata
from airflow.kubernetes.kubernetes_helper_functions import
annotations_to_key # → from
airflow.providers.cncf.kubernetes.kubernetes_helper_functions import
annotations_to_key
from airflow.kubernetes.kubernetes_helper_functions import
get_logs_task_metadata # → from
airflow.providers.cncf.kubernetes.kubernetes_helper_functions import
get_logs_task_metadata
from airflow.kubernetes.kubernetes_helper_functions import rand_str # → from
airflow.providers.cncf.kubernetes.kubernetes_helper_functions import rand_str
from airflow.kubernetes.pod import Port # → from kubernetes.client.models
import V1ContainerPort
from airflow.kubernetes.pod import Resources # → from
kubernetes.client.models import V1ResourceRequirements
from airflow.kubernetes.pod_generator import
datetime_to_label_safe_datestring # → from
airflow.providers.cncf.kubernetes.pod_generator import
datetime_to_label_safe_datestring
from airflow.kubernetes.pod_generator import extend_object_field # → from
airflow.providers.cncf.kubernetes.pod_generator import extend_object_field
from airflow.kubernetes.pod_generator import
label_safe_datestring_to_datetime # → from
airflow.providers.cncf.kubernetes.pod_generator import
label_safe_datestring_to_datetime
from airflow.kubernetes.pod_generator import make_safe_label_value # → from
airflow.providers.cncf.kubernetes.pod_generator import make_safe_label_value
from airflow.kubernetes.pod_generator import merge_objects # → from
airflow.providers.cncf.kubernetes.pod_generator import merge_objects
from airflow.kubernetes.pod_generator import PodGenerator # → from
airflow.providers.cncf.kubernetes.pod_generator import PodGenerator
from airflow.kubernetes.pod_generator import PodDefaults # → from
airflow.providers.cncf.kubernetes.utils.xcom_sidecar import PodDefaults
from airflow.kubernetes.pod_generator import PodGeneratorDeprecated # →
from airflow.providers.cncf.kubernetes.pod_generator import PodGenerator
from airflow.kubernetes.pod_generator import add_pod_suffix # → from
airflow.providers.cncf.kubernetes.kubernetes_helper_functions import
add_unique_suffix
from airflow.kubernetes.pod_generator import rand_str # → from
airflow.providers.cncf.kubernetes.kubernetes_helper_functions import rand_str
from airflow.kubernetes.pod_generator_deprecated import
make_safe_label_value # → from airflow.providers.cncf.kubernetes.pod_generator
import make_safe_label_value
from airflow.kubernetes.pod_generator_deprecated import PodGenerator # →
from airflow.providers.cncf.kubernetes.pod_generator import PodGenerator
from airflow.kubernetes.pod_generator_deprecated import PodDefaults # → from
airflow.providers.cncf.kubernetes.utils.xcom_sidecar import PodDefaults
from airflow.kubernetes.pod_launcher_deprecated import PodDefaults # → from
airflow.providers.cncf.kubernetes.utils.xcom_sidecar import PodDefaults
from airflow.kubernetes.pod_launcher_deprecated import get_kube_client # →
from airflow.providers.cncf.kubernetes.kube_client import get_kube_client
from airflow.kubernetes.pod_launcher import PodLauncher # → from
airflow.providers.cncf.kubernetes.utils.pod_manager import PodManager
from airflow.kubernetes.pod_launcher_deprecated import PodLauncher # → from
airflow.providers.cncf.kubernetes.utils.pod_manager import PodManager
from airflow.kubernetes.pod_launcher import PodStatus # → from
airflow.providers.cncf.kubernetes.utils.pod_manager import PodPhase
from airflow.kubernetes.pod_launcher_deprecated import PodStatus # → from
airflow.providers.cncf.kubernetes.utils.pod_manager import PodPhase
from airflow.kubernetes.pod_runtime_info_env import PodRuntimeInfoEnv # →
from kubernetes.client.models import V1EnvVar
from airflow.kubernetes.secret import K8SModel # → from
airflow.providers.cncf.kubernetes.k8s_model import K8SModel
from airflow.kubernetes.secret import Secret # → from
airflow.providers.cncf.kubernetes.secret import Secret
from airflow.kubernetes.volume import Volume# → from
kubernetes.client.models import V1Volume
from airflow.kubernetes.volume_mount import VolumeMount # → from
kubernetes.client.models import V1VolumeMount
# apache-airflow-providers-microsoft-mssql
from airflow.hooks.mssql_hook import MsSqlHook # → from
airflow.providers.microsoft.mssql.hooks.mssql import MsSqlHook
# apache-airflow-providers-mysql
from airflow.hooks.mysql_hook import MySqlHook # → from
airflow.providers.mysql.hooks.mysql import MySqlHook
from airflow.operators.presto_to_mysql import PrestoToMySqlOperator # → from
airflow.providers.mysql.transfers.presto_to_mysql import PrestoToMySqlOperator
from airflow.operators.presto_to_mysql import PrestoToMySqlTransfer # → from
airflow.providers.mysql.transfers.presto_to_mysql import PrestoToMySqlOperator
# apache-airflow-providers-oracle
from airflow.hooks.oracle_hook import OracleHook # → from
airflow.providers.oracle.hooks.oracle import OracleHook
# apache-airflow-providers-papermill
from airflow.operators.papermill_operator import PapermillOperator # → from
airflow.providers.papermill.operators.papermill import PapermillOperator
# apache-airflow-providers-apache-pig
from airflow.hooks.pig_hook import PigCliHook # → from
airflow.providers.apache.pig.hooks.pig import PigCliHook
from airflow.operators.pig_operator import PigOperator # → from
airflow.providers.apache.pig.operators.pig import PigOperator
# apache-airflow-providers-postgres
from airflow.hooks.postgres_hook import PostgresHook # → from
airflow.providers.postgres.hooks.postgres import PostgresHook
from airflow.operators.postgres_operator import Mapping
# apache-airflow-providers-presto
from airflow.hooks.presto_hook import PrestoHook # → from
airflow.providers.presto.hooks.presto import PrestoHook
# apache-airflow-providers-samba
from airflow.hooks.samba_hook import SambaHook # → from
airflow.providers.samba.hooks.samba import SambaHook
# apache-airflow-providers-slack
from airflow.hooks.slack_hook import SlackHook # → from
airflow.providers.slack.hooks.slack import SlackHook
from airflow.operators.slack_operator import SlackAPIOperator # → from
airflow.providers.slack.operators.slack import SlackAPIOperator
from airflow.operators.slack_operator import SlackAPIPostOperator # → from
airflow.providers.slack.operators.slack import SlackAPIPostOperator
# apache-airflow-providers-smtp
from airflow.operators.email_operator import EmailOperator # → from
airflow.providers.smtp.operators.smtp import EmailOperator
from airflow.operators.email import EmailOperator # → from
airflow.providers.smtp.operators.smtp import EmailOperator
# apache-airflow-providers-sqlite
from airflow.hooks.sqlite_hook import SqliteHook # → from
airflow.providers.sqlite.hooks.sqlite import SqliteHook
# apache-airflow-providers-zendesk
from airflow.hooks.zendesk_hook import ZendeskHook # → from
airflow.providers.zendesk.hooks.zendesk import ZendeskHook
# apache-airflow-providers-standard
from airflow.hooks.subprocess import SubprocessResult # → from
airflow.providers.standard.hooks.subprocess import SubprocessResult
from airflow.hooks.subprocess import working_directory # → from
airflow.providers.standard.hooks.subprocess import working_directory
from airflow.operators.bash_operator import BashOperator # → from
airflow.providers.standard.operators.bash import BashOperator
from airflow.operators.dagrun_operator import TriggerDagRunLink # → from
airflow.providers.standard.operators.trigger_dagrun import TriggerDagRunLink
from airflow.operators.dagrun_operator import TriggerDagRunOperator # → from
airflow.providers.standard.operators.trigger_dagrun import TriggerDagRunOperator
from airflow.operators.trigger_dagrun import TriggerDagRunLink # → from
airflow.providers.standard.operators.trigger_dagrun import TriggerDagRunLink
from airflow.operators.datetime import target_times_as_dates # → from
airflow.providers.standard.operators.datetime import target_times_as_dates
from airflow.operators.dummy import DummyOperator # → from
airflow.providers.standard.operators.empty import EmptyOperator
from airflow.operators.dummy import EmptyOperator # → from
airflow.providers.standard.operators.empty import EmptyOperator
from airflow.operators.dummy_operator import DummyOperator # → from
airflow.providers.standard.operators.empty import EmptyOperator
from airflow.operators.dummy_operator import EmptyOperator # → from
airflow.providers.standard.operators.empty import EmptyOperator
from airflow.operators.latest_only_operator import LatestOnlyOperator # →
from airflow.providers.standard.operators.latest_only import LatestOnlyOperator
from airflow.operators.python_operator import BranchPythonOperator # → from
airflow.providers.standard.operators.python import BranchPythonOperator
from airflow.operators.python_operator import PythonOperator # → from
airflow.providers.standard.operators.python import PythonOperator
from airflow.operators.python_operator import PythonVirtualenvOperator # →
from airflow.providers.standard.operators.python import PythonVirtualenvOperator
from airflow.operators.python_operator import ShortCircuitOperator # → from
airflow.providers.standard.operators.python import ShortCircuitOperator
from airflow.sensors.external_task import ExternalTaskSensorLink # → from
airflow.providers.standard.sensors.external_task import ExternalDagLink
from airflow.sensors.external_task_sensor import ExternalTaskMarker # → from
airflow.providers.standard.sensors.external_task import ExternalTaskMarker
from airflow.sensors.external_task_sensor import ExternalTaskSensor # → from
airflow.providers.standard.sensors.external_task import ExternalTaskSensor
from airflow.sensors.external_task_sensor import ExternalTaskSensorLink # →
from airflow.providers.standard.sensors.external_task import ExternalDagLink
from airflow.sensors.time_delta import WaitSensor # → from
airflow.providers.standard.sensors.time_delta import WaitSensor
</details>
<details>
<summary> AIR312 </summary>
# AIR312
from airflow.hooks.filesystem import FSHook # → from
airflow.providers.standard.hooks.filesystem import FSHook
from airflow.hooks.package_index import PackageIndexHook # → from
airflow.providers.standard.hooks.package_index import PackageIndexHook
from airflow.hooks.subprocess import SubprocessHook # → from
airflow.providers.standard.hooks.subprocess import SubprocessHook
# from airflow.hooks.subprocess import SubprocessResult # → from
airflow.providers.standard.hooks.subprocess import SubprocessResult
# from airflow.hooks.subprocess import working_directory # → from
airflow.providers.standard.hooks.subprocess import working_directory
from airflow.operators.bash import BashOperator # → from
airflow.providers.standard.operators.bash import BashOperator
from airflow.operators.datetime import BranchDateTimeOperator # → from
airflow.providers.standard.operators.datetime import BranchDateTimeOperator
# from airflow.operators.datetime import target_times_as_dates # → from
airflow.providers.standard.operators.datetime import target_times_as_dates
# from airflow.operators.trigger_dagrun import TriggerDagRunLink # → from
airflow.providers.standard.operators.trigger_dagrun import TriggerDagRunLink
from airflow.operators.trigger_dagrun import TriggerDagRunOperator # → from
airflow.providers.standard.operators.trigger_dagrun import TriggerDagRunOperator
from airflow.operators.empty import EmptyOperator # → from
airflow.providers.standard.operators.empty import EmptyOperator
from airflow.operators.latest_only import LatestOnlyOperator # → from
airflow.providers.standard.operators.latest_only import LatestOnlyOperator
from airflow.operators.python import BranchPythonOperator # → from
irflow.providers.standard.operators.python import BranchPythonOperator
from airflow.operators.python import PythonOperator # → from
irflow.providers.standard.operators.python import PythonOperator
from airflow.operators.python import PythonVirtualenvOperator # → from
irflow.providers.standard.operators.python import PythonVirtualenvOperator
from airflow.operators.python import ShortCircuitOperator # → from
irflow.providers.standard.operators.python import ShortCircuitOperator
from airflow.operators.weekday import BranchDayOfWeekOperator # → from
airflow.providers.standard.operators.weekday import BranchDayOfWeekOperator
from airflow.sensors.date_time import DateTimeSensor # → from
airflow.providers.standard.sensors.date_time import DateTimeSensor
from airflow.sensors.date_time import DateTimeSensorAsync # → from
airflow.providers.standard.sensors.date_time import DateTimeSensorAsync
from airflow.sensors.external_task import ExternalTaskMarker # → from
airflow.providers.standard.sensors.external_task import ExternalTaskMarker
from airflow.sensors.external_task import ExternalTaskSensor # → from
airflow.providers.standard.sensors.external_task import ExternalTaskSensor
# from airflow.sensors.external_task import ExternalTaskSensorLink # → from
airflow.providers.standard.sensors.external_task import ExternalDagLink
from airflow.sensors.filesystem import FileSensor # → from
airflow.providers.standard.sensors.filesystem import FileSensor
from airflow.sensors.time_sensor import TimeSensor # → from
airflow.providers.standard.sensors.time import TimeSensor
from airflow.sensors.time_sensor import TimeSensorAsync # → from
airflow.providers.standard.sensors.time import TimeSensorAsync
from airflow.sensors.time_delta import TimeDeltaSensor # → from
airflow.providers.standard.sensors.time_delta import TimeDeltaSensor
from airflow.sensors.time_delta import TimeDeltaSensorAsync # → from
airflow.providers.standard.sensors.time_delta import TimeDeltaSensorAsync
# from airflow.sensors.time_delta import WaitSensor # → from
airflow.providers.standard.sensors.time_delta import WaitSensor
from airflow.sensors.weekday import DayOfWeekSensor # → from
airflow.providers.standard.sensors.weekday import DayOfWeekSensor
from airflow.triggers.external_task import DagStateTrigger # → from
airflow.providers.standard.triggers.external_task import DagStateTrigger
from airflow.triggers.external_task import WorkflowTrigger # → from
airflow.providers.standard.triggers.external_task import WorkflowTrigger
from airflow.triggers.file import FileTrigger # → from
airflow.providers.standard.triggers.file import FileTrigger
from airflow.triggers.temporal import DateTimeTrigger # → from
airflow.providers.standard.triggers.temporal import DateTimeTrigger
from airflow.triggers.temporal import TimeDeltaTrigger # → from
airflow.providers.standard.triggers.temporal import TimeDeltaTrigger
</details>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
