This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from e789a2ba9f Fix constraint upgrade (#27221)
add 2a34dc9e84 Enable string normalization in python formatting -
providers (#27205)
No new revisions were added by this update.
Summary of changes:
.pre-commit-config.yaml | 11 +-
STATIC_CODE_CHECKS.rst | 3 +-
airflow/providers/airbyte/hooks/airbyte.py | 16 +-
airflow/providers/airbyte/operators/airbyte.py | 10 +-
airflow/providers/airbyte/sensors/airbyte.py | 8 +-
airflow/providers/alibaba/cloud/hooks/oss.py | 44 +-
.../alibaba/cloud/log/oss_task_handler.py | 24 +-
airflow/providers/alibaba/cloud/operators/oss.py | 12 +-
airflow/providers/alibaba/cloud/sensors/oss_key.py | 20 +-
.../aws/example_dags/example_eks_templated.py | 20 +-
.../amazon/aws/example_dags/example_emr.py | 60 +--
.../aws/example_dags/example_glacier_to_gcs.py | 2 +-
.../example_google_api_sheets_to_s3.py | 12 +-
.../aws/example_dags/example_hive_to_dynamodb.py | 48 +--
.../example_dags/example_imap_attachment_to_s3.py | 4 +-
airflow/providers/amazon/aws/hooks/athena.py | 62 +--
airflow/providers/amazon/aws/hooks/base_aws.py | 96 ++---
airflow/providers/amazon/aws/hooks/batch_client.py | 24 +-
.../providers/amazon/aws/hooks/cloud_formation.py | 18 +-
airflow/providers/amazon/aws/hooks/datasync.py | 2 +-
airflow/providers/amazon/aws/hooks/dms.py | 30 +-
airflow/providers/amazon/aws/hooks/ecs.py | 64 +--
airflow/providers/amazon/aws/hooks/eks.py | 82 ++--
.../aws/hooks/elasticache_replication_group.py | 24 +-
airflow/providers/amazon/aws/hooks/emr.py | 64 +--
airflow/providers/amazon/aws/hooks/glacier.py | 4 +-
airflow/providers/amazon/aws/hooks/glue.py | 60 +--
airflow/providers/amazon/aws/hooks/glue_catalog.py | 18 +-
airflow/providers/amazon/aws/hooks/glue_crawler.py | 32 +-
airflow/providers/amazon/aws/hooks/logs.py | 8 +-
airflow/providers/amazon/aws/hooks/rds.py | 2 +-
.../providers/amazon/aws/hooks/redshift_cluster.py | 22 +-
.../providers/amazon/aws/hooks/redshift_data.py | 2 +-
airflow/providers/amazon/aws/hooks/redshift_sql.py | 26 +-
airflow/providers/amazon/aws/hooks/s3.py | 168 ++++----
airflow/providers/amazon/aws/hooks/sagemaker.py | 148 +++----
.../providers/amazon/aws/hooks/secrets_manager.py | 8 +-
airflow/providers/amazon/aws/hooks/ses.py | 12 +-
airflow/providers/amazon/aws/hooks/sns.py | 24 +-
airflow/providers/amazon/aws/hooks/sqs.py | 10 +-
.../providers/amazon/aws/hooks/step_function.py | 12 +-
airflow/providers/amazon/aws/hooks/sts.py | 2 +-
.../amazon/aws/log/cloudwatch_task_handler.py | 24 +-
.../providers/amazon/aws/log/s3_task_handler.py | 28 +-
airflow/providers/amazon/aws/operators/athena.py | 30 +-
airflow/providers/amazon/aws/operators/batch.py | 38 +-
.../amazon/aws/operators/cloud_formation.py | 18 +-
airflow/providers/amazon/aws/operators/datasync.py | 18 +-
airflow/providers/amazon/aws/operators/dms.py | 44 +-
airflow/providers/amazon/aws/operators/ecs.py | 160 +++----
airflow/providers/amazon/aws/operators/eks.py | 30 +-
airflow/providers/amazon/aws/operators/emr.py | 188 ++++-----
airflow/providers/amazon/aws/operators/glue.py | 30 +-
.../providers/amazon/aws/operators/glue_crawler.py | 8 +-
.../amazon/aws/operators/lambda_function.py | 12 +-
airflow/providers/amazon/aws/operators/rds.py | 54 +--
.../amazon/aws/operators/redshift_cluster.py | 12 +-
.../amazon/aws/operators/redshift_data.py | 38 +-
.../providers/amazon/aws/operators/redshift_sql.py | 8 +-
airflow/providers/amazon/aws/operators/s3.py | 50 +--
.../providers/amazon/aws/operators/sagemaker.py | 250 +++++------
airflow/providers/amazon/aws/operators/sns.py | 6 +-
airflow/providers/amazon/aws/operators/sqs.py | 18 +-
.../amazon/aws/operators/step_function.py | 20 +-
.../amazon/aws/secrets/secrets_manager.py | 54 +--
.../amazon/aws/secrets/systems_manager.py | 10 +-
airflow/providers/amazon/aws/sensors/athena.py | 18 +-
airflow/providers/amazon/aws/sensors/batch.py | 40 +-
.../amazon/aws/sensors/cloud_formation.py | 24 +-
airflow/providers/amazon/aws/sensors/dms.py | 30 +-
airflow/providers/amazon/aws/sensors/ecs.py | 10 +-
airflow/providers/amazon/aws/sensors/emr.py | 72 ++--
airflow/providers/amazon/aws/sensors/glacier.py | 2 +-
airflow/providers/amazon/aws/sensors/glue.py | 14 +-
.../amazon/aws/sensors/glue_catalog_partition.py | 18 +-
.../providers/amazon/aws/sensors/glue_crawler.py | 14 +-
airflow/providers/amazon/aws/sensors/quicksight.py | 2 +-
airflow/providers/amazon/aws/sensors/rds.py | 48 +--
.../amazon/aws/sensors/redshift_cluster.py | 8 +-
airflow/providers/amazon/aws/sensors/s3.py | 20 +-
airflow/providers/amazon/aws/sensors/sagemaker.py | 62 +--
airflow/providers/amazon/aws/sensors/sqs.py | 38 +-
.../providers/amazon/aws/sensors/step_function.py | 26 +-
.../amazon/aws/transfers/dynamodb_to_s3.py | 20 +-
.../providers/amazon/aws/transfers/exasol_to_s3.py | 10 +-
.../providers/amazon/aws/transfers/ftp_to_s3.py | 16 +-
.../providers/amazon/aws/transfers/gcs_to_s3.py | 20 +-
.../amazon/aws/transfers/google_api_to_s3.py | 22 +-
.../amazon/aws/transfers/hive_to_dynamodb.py | 20 +-
.../amazon/aws/transfers/imap_attachment_to_s3.py | 12 +-
.../providers/amazon/aws/transfers/local_to_s3.py | 6 +-
.../providers/amazon/aws/transfers/mongo_to_s3.py | 10 +-
.../amazon/aws/transfers/redshift_to_s3.py | 38 +-
.../providers/amazon/aws/transfers/s3_to_ftp.py | 10 +-
.../amazon/aws/transfers/s3_to_redshift.py | 44 +-
.../providers/amazon/aws/transfers/s3_to_sftp.py | 8 +-
.../providers/amazon/aws/transfers/sftp_to_s3.py | 10 +-
.../providers/amazon/aws/transfers/sql_to_s3.py | 26 +-
airflow/providers/amazon/aws/utils/__init__.py | 4 +-
.../amazon/aws/utils/connection_wrapper.py | 6 +-
.../providers/amazon/aws/utils/eks_get_token.py | 16 +-
airflow/providers/amazon/aws/utils/emailer.py | 6 +-
airflow/providers/apache/beam/operators/beam.py | 12 +-
.../providers/apache/cassandra/hooks/cassandra.py | 64 +--
.../providers/apache/cassandra/sensors/record.py | 4 +-
.../providers/apache/cassandra/sensors/table.py | 4 +-
airflow/providers/apache/drill/hooks/drill.py | 24 +-
airflow/providers/apache/drill/operators/drill.py | 10 +-
airflow/providers/apache/druid/hooks/druid.py | 50 +--
airflow/providers/apache/druid/operators/druid.py | 8 +-
.../apache/druid/operators/druid_check.py | 2 +-
.../apache/druid/transfers/hive_to_druid.py | 26 +-
airflow/providers/apache/hdfs/hooks/hdfs.py | 22 +-
airflow/providers/apache/hdfs/hooks/webhdfs.py | 24 +-
airflow/providers/apache/hdfs/sensors/hdfs.py | 40 +-
airflow/providers/apache/hdfs/sensors/web_hdfs.py | 6 +-
airflow/providers/apache/hive/hooks/hive.py | 240 +++++------
airflow/providers/apache/hive/operators/hive.py | 40 +-
.../providers/apache/hive/operators/hive_stats.py | 62 +--
.../apache/hive/sensors/hive_partition.py | 20 +-
.../apache/hive/sensors/metastore_partition.py | 8 +-
.../apache/hive/sensors/named_hive_partition.py | 22 +-
.../apache/hive/transfers/hive_to_mysql.py | 22 +-
.../apache/hive/transfers/hive_to_samba.py | 14 +-
.../apache/hive/transfers/mssql_to_hive.py | 24 +-
.../apache/hive/transfers/mysql_to_hive.py | 38 +-
.../providers/apache/hive/transfers/s3_to_hive.py | 28 +-
.../apache/hive/transfers/vertica_to_hive.py | 30 +-
airflow/providers/apache/kylin/hooks/kylin.py | 2 +-
.../providers/apache/kylin/operators/kylin_cube.py | 56 +--
airflow/providers/apache/livy/hooks/livy.py | 92 ++--
airflow/providers/apache/livy/operators/livy.py | 38 +-
airflow/providers/apache/livy/sensors/livy.py | 4 +-
airflow/providers/apache/pig/hooks/pig.py | 24 +-
airflow/providers/apache/pig/operators/pig.py | 12 +-
airflow/providers/apache/pinot/hooks/pinot.py | 20 +-
airflow/providers/apache/spark/hooks/spark_jdbc.py | 66 +--
.../apache/spark/hooks/spark_jdbc_script.py | 76 ++--
airflow/providers/apache/spark/hooks/spark_sql.py | 10 +-
.../providers/apache/spark/hooks/spark_submit.py | 114 ++---
.../providers/apache/spark/operators/spark_jdbc.py | 8 +-
.../providers/apache/spark/operators/spark_sql.py | 8 +-
.../apache/spark/operators/spark_submit.py | 36 +-
airflow/providers/apache/sqoop/hooks/sqoop.py | 34 +-
airflow/providers/apache/sqoop/operators/sqoop.py | 70 ++--
.../arangodb/example_dags/example_arangodb.py | 8 +-
airflow/providers/arangodb/hooks/arangodb.py | 34 +-
airflow/providers/arangodb/operators/arangodb.py | 6 +-
airflow/providers/arangodb/sensors/arangodb.py | 2 +-
airflow/providers/asana/hooks/asana.py | 14 +-
airflow/providers/atlassian/jira/hooks/jira.py | 18 +-
airflow/providers/atlassian/jira/operators/jira.py | 2 +-
airflow/providers/atlassian/jira/sensors/jira.py | 10 +-
airflow/providers/celery/sensors/celery_queue.py | 6 +-
airflow/providers/cloudant/hooks/cloudant.py | 16 +-
airflow/providers/cncf/kubernetes/__init__.py | 2 +-
.../providers/cncf/kubernetes/backcompat/pod.py | 30 +-
.../providers/cncf/kubernetes/backcompat/volume.py | 2 +-
.../cncf/kubernetes/backcompat/volume_mount.py | 2 +-
.../cncf/kubernetes/decorators/kubernetes.py | 8 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 34 +-
.../cncf/kubernetes/operators/kubernetes_pod.py | 86 ++--
.../cncf/kubernetes/operators/spark_kubernetes.py | 12 +-
.../cncf/kubernetes/python_kubernetes_script.py | 4 +-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 4 +-
.../providers/cncf/kubernetes/utils/__init__.py | 2 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 44 +-
.../cncf/kubernetes/utils/xcom_sidecar.py | 12 +-
airflow/providers/common/sql/hooks/sql.py | 14 +-
airflow/providers/common/sql/operators/sql.py | 36 +-
airflow/providers/common/sql/sensors/sql.py | 16 +-
airflow/providers/databricks/hooks/databricks.py | 100 ++---
.../providers/databricks/hooks/databricks_base.py | 182 ++++----
.../providers/databricks/hooks/databricks_sql.py | 18 +-
.../providers/databricks/operators/databricks.py | 152 +++----
.../databricks/operators/databricks_repos.py | 22 +-
.../databricks/operators/databricks_sql.py | 48 +--
.../providers/databricks/triggers/databricks.py | 16 +-
airflow/providers/databricks/utils/databricks.py | 14 +-
airflow/providers/datadog/hooks/datadog.py | 12 +-
airflow/providers/datadog/sensors/datadog.py | 6 +-
airflow/providers/dbt/cloud/hooks/dbt.py | 2 +-
airflow/providers/dbt/cloud/operators/dbt.py | 2 +-
airflow/providers/dingding/hooks/dingding.py | 42 +-
airflow/providers/dingding/operators/dingding.py | 10 +-
airflow/providers/discord/hooks/discord_webhook.py | 30 +-
.../providers/discord/operators/discord_webhook.py | 4 +-
airflow/providers/docker/decorators/docker.py | 20 +-
airflow/providers/docker/hooks/docker.py | 36 +-
airflow/providers/docker/operators/docker.py | 64 +--
airflow/providers/docker/operators/docker_swarm.py | 40 +-
.../providers/elasticsearch/hooks/elasticsearch.py | 26 +-
.../elasticsearch/log/es_json_formatter.py | 6 +-
.../providers/elasticsearch/log/es_task_handler.py | 68 +--
airflow/providers/exasol/hooks/exasol.py | 14 +-
airflow/providers/exasol/operators/exasol.py | 14 +-
airflow/providers/facebook/ads/hooks/ads.py | 18 +-
airflow/providers/ftp/hooks/ftp.py | 24 +-
airflow/providers/ftp/sensors/ftp.py | 10 +-
airflow/providers/github/hooks/github.py | 14 +-
airflow/providers/github/operators/github.py | 4 +-
airflow/providers/github/sensors/github.py | 12 +-
airflow/providers/google/__init__.py | 4 +-
airflow/providers/google/ads/hooks/ads.py | 4 +-
.../_internal_client/secret_manager_client.py | 4 +-
.../example_automl_nl_text_classification.py | 6 +-
.../example_automl_nl_text_sentiment.py | 6 +-
.../cloud/example_dags/example_automl_tables.py | 8 +-
.../example_dags/example_automl_translation.py | 2 +-
...ple_automl_video_intelligence_classification.py | 2 +-
.../example_automl_video_intelligence_tracking.py | 2 +-
.../example_automl_vision_object_detection.py | 2 +-
.../cloud/example_dags/example_bigquery_dts.py | 2 +-
.../google/cloud/example_dags/example_bigtable.py | 58 +--
.../cloud/example_dags/example_cloud_composer.py | 4 +-
.../cloud/example_dags/example_cloud_sql_query.py | 78 ++--
.../example_cloud_storage_transfer_service_aws.py | 18 +-
.../cloud/example_dags/example_cloud_task.py | 12 +-
.../google/cloud/example_dags/example_compute.py | 28 +-
.../cloud/example_dags/example_compute_ssh.py | 10 +-
.../google/cloud/example_dags/example_dataflow.py | 76 ++--
.../example_dags/example_dataflow_flex_template.py | 10 +-
.../cloud/example_dags/example_dataflow_sql.py | 2 +-
.../cloud/example_dags/example_datafusion.py | 20 +-
.../google/cloud/example_dags/example_dataprep.py | 4 +-
.../example_dags/example_facebook_ads_to_gcs.py | 20 +-
.../google/cloud/example_dags/example_looker.py | 22 +-
.../google/cloud/example_dags/example_mlengine.py | 72 ++--
.../cloud/example_dags/example_postgres_to_gcs.py | 4 +-
.../cloud/example_dags/example_presto_to_gcs.py | 2 +-
.../example_dags/example_salesforce_to_gcs.py | 22 +-
.../google/cloud/example_dags/example_vertex_ai.py | 40 +-
.../google/cloud/example_dags/example_vision.py | 94 ++---
airflow/providers/google/cloud/hooks/automl.py | 34 +-
airflow/providers/google/cloud/hooks/bigquery.py | 466 ++++++++++-----------
.../providers/google/cloud/hooks/bigquery_dts.py | 16 +-
.../providers/google/cloud/hooks/cloud_build.py | 36 +-
.../providers/google/cloud/hooks/cloud_composer.py | 20 +-
.../google/cloud/hooks/cloud_memorystore.py | 22 +-
airflow/providers/google/cloud/hooks/cloud_sql.py | 128 +++---
.../cloud/hooks/cloud_storage_transfer_service.py | 76 ++--
airflow/providers/google/cloud/hooks/compute.py | 6 +-
.../providers/google/cloud/hooks/compute_ssh.py | 46 +-
.../providers/google/cloud/hooks/datacatalog.py | 132 +++---
airflow/providers/google/cloud/hooks/dataflow.py | 20 +-
airflow/providers/google/cloud/hooks/dataform.py | 4 +-
airflow/providers/google/cloud/hooks/dataplex.py | 30 +-
airflow/providers/google/cloud/hooks/dataprep.py | 10 +-
airflow/providers/google/cloud/hooks/dataproc.py | 216 +++++-----
.../google/cloud/hooks/dataproc_metastore.py | 96 ++---
airflow/providers/google/cloud/hooks/datastore.py | 42 +-
airflow/providers/google/cloud/hooks/functions.py | 16 +-
airflow/providers/google/cloud/hooks/gcs.py | 90 ++--
airflow/providers/google/cloud/hooks/gdm.py | 6 +-
airflow/providers/google/cloud/hooks/kms.py | 12 +-
.../google/cloud/hooks/kubernetes_engine.py | 18 +-
.../providers/google/cloud/hooks/life_sciences.py | 6 +-
airflow/providers/google/cloud/hooks/looker.py | 42 +-
airflow/providers/google/cloud/hooks/mlengine.py | 94 ++---
airflow/providers/google/cloud/hooks/os_login.py | 2 +-
airflow/providers/google/cloud/hooks/pubsub.py | 40 +-
.../providers/google/cloud/hooks/secret_manager.py | 2 +-
airflow/providers/google/cloud/hooks/spanner.py | 10 +-
.../providers/google/cloud/hooks/stackdriver.py | 52 +--
airflow/providers/google/cloud/hooks/tasks.py | 38 +-
.../google/cloud/hooks/vertex_ai/auto_ml.py | 22 +-
.../cloud/hooks/vertex_ai/batch_prediction_job.py | 18 +-
.../google/cloud/hooks/vertex_ai/custom_job.py | 70 ++--
.../google/cloud/hooks/vertex_ai/dataset.py | 66 +--
.../cloud/hooks/vertex_ai/endpoint_service.py | 42 +-
.../hooks/vertex_ai/hyperparameter_tuning_job.py | 18 +-
.../google/cloud/hooks/vertex_ai/model_service.py | 18 +-
airflow/providers/google/cloud/hooks/vision.py | 90 ++--
.../google/cloud/links/cloud_storage_transfer.py | 2 +-
.../providers/google/cloud/log/gcs_task_handler.py | 16 +-
.../google/cloud/log/stackdriver_task_handler.py | 26 +-
.../providers/google/cloud/operators/bigquery.py | 260 ++++++------
.../google/cloud/operators/bigquery_dts.py | 6 +-
.../providers/google/cloud/operators/bigtable.py | 84 ++--
.../google/cloud/operators/cloud_build.py | 6 +-
.../google/cloud/operators/cloud_composer.py | 48 +--
.../providers/google/cloud/operators/cloud_sql.py | 170 ++++----
.../operators/cloud_storage_transfer_service.py | 128 +++---
.../providers/google/cloud/operators/compute.py | 116 ++---
.../google/cloud/operators/datacatalog.py | 2 +-
.../providers/google/cloud/operators/datafusion.py | 4 +-
.../providers/google/cloud/operators/dataplex.py | 6 +-
.../providers/google/cloud/operators/dataproc.py | 382 ++++++++---------
.../google/cloud/operators/dataproc_metastore.py | 56 +--
.../providers/google/cloud/operators/datastore.py | 62 +--
airflow/providers/google/cloud/operators/dlp.py | 10 +-
.../providers/google/cloud/operators/functions.py | 100 ++---
airflow/providers/google/cloud/operators/gcs.py | 126 +++---
.../google/cloud/operators/kubernetes_engine.py | 48 +--
airflow/providers/google/cloud/operators/looker.py | 2 +-
.../providers/google/cloud/operators/mlengine.py | 318 +++++++-------
airflow/providers/google/cloud/operators/pubsub.py | 64 +--
.../providers/google/cloud/operators/spanner.py | 106 ++---
.../google/cloud/operators/stackdriver.py | 84 ++--
.../providers/google/cloud/operators/translate.py | 18 +-
.../google/cloud/operators/translate_speech.py | 24 +-
.../google/cloud/operators/vertex_ai/auto_ml.py | 20 +-
.../google/cloud/operators/vertex_ai/custom_job.py | 18 +-
.../vertex_ai/hyperparameter_tuning_job.py | 6 +-
airflow/providers/google/cloud/operators/vision.py | 112 ++---
.../providers/google/cloud/operators/workflows.py | 2 +-
.../google/cloud/secrets/secret_manager.py | 10 +-
airflow/providers/google/cloud/sensors/bigquery.py | 32 +-
airflow/providers/google/cloud/sensors/bigtable.py | 12 +-
.../sensors/cloud_storage_transfer_service.py | 8 +-
airflow/providers/google/cloud/sensors/dataflow.py | 16 +-
airflow/providers/google/cloud/sensors/dataform.py | 4 +-
.../providers/google/cloud/sensors/datafusion.py | 4 +-
airflow/providers/google/cloud/sensors/dataplex.py | 2 +-
airflow/providers/google/cloud/sensors/dataproc.py | 10 +-
airflow/providers/google/cloud/sensors/gcs.py | 46 +-
airflow/providers/google/cloud/sensors/looker.py | 8 +-
airflow/providers/google/cloud/sensors/pubsub.py | 10 +-
.../google/cloud/transfers/adls_to_gcs.py | 12 +-
.../cloud/transfers/azure_fileshare_to_gcs.py | 24 +-
.../google/cloud/transfers/bigquery_to_bigquery.py | 20 +-
.../google/cloud/transfers/bigquery_to_gcs.py | 46 +-
.../google/cloud/transfers/bigquery_to_mssql.py | 12 +-
.../google/cloud/transfers/bigquery_to_mysql.py | 16 +-
.../google/cloud/transfers/cassandra_to_gcs.py | 154 +++----
.../google/cloud/transfers/gcs_to_bigquery.py | 36 +-
.../providers/google/cloud/transfers/gcs_to_gcs.py | 40 +-
.../google/cloud/transfers/gcs_to_local.py | 26 +-
.../google/cloud/transfers/gdrive_to_local.py | 2 +-
.../google/cloud/transfers/local_to_gcs.py | 12 +-
.../google/cloud/transfers/mssql_to_gcs.py | 12 +-
.../google/cloud/transfers/mysql_to_gcs.py | 46 +-
.../google/cloud/transfers/oracle_to_gcs.py | 34 +-
.../google/cloud/transfers/postgres_to_gcs.py | 38 +-
.../providers/google/cloud/transfers/s3_to_gcs.py | 32 +-
.../google/cloud/transfers/salesforce_to_gcs.py | 10 +-
.../providers/google/cloud/transfers/sql_to_gcs.py | 162 +++----
.../google/cloud/triggers/cloud_composer.py | 4 +-
.../google/cloud/utils/bigquery_get_data.py | 8 +-
.../google/cloud/utils/credentials_provider.py | 30 +-
.../google/cloud/utils/field_validator.py | 54 +--
.../google/cloud/utils/mlengine_operator_utils.py | 16 +-
.../cloud/utils/mlengine_prediction_summary.py | 2 +-
airflow/providers/google/common/consts.py | 4 +-
.../providers/google/common/hooks/base_google.py | 104 ++---
.../providers/google/common/hooks/discovery_api.py | 4 +-
airflow/providers/google/leveldb/hooks/leveldb.py | 18 +-
.../providers/google/leveldb/operators/leveldb.py | 4 +-
.../example_dags/example_display_video.py | 4 +-
.../marketing_platform/hooks/campaign_manager.py | 8 +-
.../marketing_platform/hooks/display_video.py | 2 +-
.../operators/campaign_manager.py | 2 +-
.../marketing_platform/operators/display_video.py | 2 +-
.../marketing_platform/operators/search_ads.py | 6 +-
.../marketing_platform/sensors/search_ads.py | 4 +-
airflow/providers/google/suite/hooks/calendar.py | 10 +-
airflow/providers/google/suite/hooks/drive.py | 4 +-
airflow/providers/google/suite/hooks/sheets.py | 58 +--
airflow/providers/google/suite/sensors/drive.py | 14 +-
.../google/suite/transfers/local_to_drive.py | 4 +-
airflow/providers/grpc/hooks/grpc.py | 16 +-
airflow/providers/grpc/operators/grpc.py | 2 +-
.../hashicorp/_internal_client/vault_client.py | 32 +-
airflow/providers/hashicorp/hooks/vault.py | 44 +-
airflow/providers/hashicorp/secrets/vault.py | 18 +-
airflow/providers/http/hooks/http.py | 28 +-
airflow/providers/http/operators/http.py | 14 +-
airflow/providers/http/sensors/http.py | 8 +-
airflow/providers/imap/hooks/imap.py | 56 +--
airflow/providers/imap/sensors/imap_attachment.py | 10 +-
airflow/providers/influxdb/hooks/influxdb.py | 20 +-
airflow/providers/influxdb/operators/influxdb.py | 6 +-
airflow/providers/jdbc/hooks/jdbc.py | 22 +-
airflow/providers/jdbc/operators/jdbc.py | 10 +-
airflow/providers/jenkins/hooks/jenkins.py | 22 +-
.../jenkins/operators/jenkins_job_trigger.py | 64 +--
airflow/providers/microsoft/azure/hooks/adx.py | 62 +--
airflow/providers/microsoft/azure/hooks/asb.py | 14 +-
.../providers/microsoft/azure/hooks/base_azure.py | 50 +--
airflow/providers/microsoft/azure/hooks/batch.py | 30 +-
.../microsoft/azure/hooks/container_instance.py | 8 +-
.../microsoft/azure/hooks/container_registry.py | 24 +-
.../microsoft/azure/hooks/container_volume.py | 26 +-
airflow/providers/microsoft/azure/hooks/cosmos.py | 44 +-
.../microsoft/azure/hooks/data_factory.py | 26 +-
.../providers/microsoft/azure/hooks/data_lake.py | 32 +-
.../providers/microsoft/azure/hooks/fileshare.py | 32 +-
airflow/providers/microsoft/azure/hooks/synapse.py | 42 +-
airflow/providers/microsoft/azure/hooks/wasb.py | 90 ++--
.../microsoft/azure/log/wasb_task_handler.py | 20 +-
.../providers/microsoft/azure/operators/adls.py | 14 +-
airflow/providers/microsoft/azure/operators/adx.py | 10 +-
airflow/providers/microsoft/azure/operators/asb.py | 20 +-
.../providers/microsoft/azure/operators/batch.py | 16 +-
.../azure/operators/container_instances.py | 20 +-
.../providers/microsoft/azure/operators/cosmos.py | 6 +-
.../providers/microsoft/azure/operators/synapse.py | 2 +-
.../microsoft/azure/operators/wasb_delete_blob.py | 6 +-
.../providers/microsoft/azure/secrets/key_vault.py | 24 +-
.../providers/microsoft/azure/sensors/cosmos.py | 2 +-
airflow/providers/microsoft/azure/sensors/wasb.py | 12 +-
.../microsoft/azure/transfers/azure_blob_to_gcs.py | 2 +-
.../microsoft/azure/transfers/local_to_adls.py | 8 +-
.../microsoft/azure/transfers/local_to_wasb.py | 6 +-
.../azure/transfers/oracle_to_azure_data_lake.py | 8 +-
.../microsoft/azure/transfers/sftp_to_wasb.py | 8 +-
airflow/providers/microsoft/mssql/hooks/mssql.py | 14 +-
.../providers/microsoft/mssql/operators/mssql.py | 14 +-
airflow/providers/microsoft/psrp/hooks/psrp.py | 2 +-
airflow/providers/microsoft/psrp/operators/psrp.py | 2 +-
airflow/providers/microsoft/winrm/hooks/winrm.py | 18 +-
.../providers/microsoft/winrm/operators/winrm.py | 16 +-
airflow/providers/mongo/hooks/mongo.py | 26 +-
airflow/providers/mongo/sensors/mongo.py | 2 +-
airflow/providers/mysql/hooks/mysql.py | 76 ++--
airflow/providers/mysql/operators/mysql.py | 16 +-
.../providers/mysql/transfers/presto_to_mysql.py | 10 +-
airflow/providers/mysql/transfers/s3_to_mysql.py | 16 +-
.../providers/mysql/transfers/trino_to_mysql.py | 10 +-
.../providers/mysql/transfers/vertica_to_mysql.py | 14 +-
airflow/providers/neo4j/hooks/neo4j.py | 26 +-
airflow/providers/neo4j/operators/neo4j.py | 6 +-
airflow/providers/odbc/hooks/odbc.py | 30 +-
airflow/providers/openfaas/hooks/openfaas.py | 10 +-
airflow/providers/opsgenie/hooks/opsgenie.py | 22 +-
airflow/providers/opsgenie/operators/opsgenie.py | 10 +-
airflow/providers/oracle/hooks/oracle.py | 130 +++---
airflow/providers/oracle/operators/oracle.py | 22 +-
.../providers/oracle/transfers/oracle_to_oracle.py | 4 +-
airflow/providers/pagerduty/hooks/pagerduty.py | 6 +-
.../providers/pagerduty/hooks/pagerduty_events.py | 14 +-
airflow/providers/papermill/operators/papermill.py | 4 +-
airflow/providers/plexus/operators/job.py | 4 +-
airflow/providers/postgres/hooks/postgres.py | 48 +--
airflow/providers/postgres/operators/postgres.py | 22 +-
airflow/providers/presto/hooks/presto.py | 74 ++--
.../providers/presto/transfers/gcs_to_presto.py | 6 +-
airflow/providers/qubole/hooks/qubole.py | 68 +--
airflow/providers/qubole/hooks/qubole_check.py | 22 +-
airflow/providers/qubole/operators/qubole.py | 86 ++--
airflow/providers/qubole/operators/qubole_check.py | 20 +-
airflow/providers/qubole/sensors/qubole.py | 10 +-
airflow/providers/redis/hooks/redis.py | 12 +-
airflow/providers/redis/operators/redis_publish.py | 8 +-
airflow/providers/redis/sensors/redis_key.py | 6 +-
airflow/providers/redis/sensors/redis_pub_sub.py | 12 +-
airflow/providers/salesforce/hooks/salesforce.py | 38 +-
airflow/providers/salesforce/operators/bulk.py | 18 +-
.../salesforce/operators/salesforce_apex_rest.py | 4 +-
airflow/providers/samba/hooks/samba.py | 8 +-
airflow/providers/segment/hooks/segment.py | 22 +-
.../segment/operators/segment_track_event.py | 8 +-
airflow/providers/sendgrid/utils/emailer.py | 24 +-
airflow/providers/sftp/hooks/sftp.py | 38 +-
airflow/providers/sftp/operators/sftp.py | 22 +-
airflow/providers/sftp/sensors/sftp.py | 10 +-
.../providers/singularity/operators/singularity.py | 40 +-
airflow/providers/slack/hooks/slack.py | 30 +-
airflow/providers/slack/hooks/slack_webhook.py | 24 +-
airflow/providers/slack/operators/slack.py | 46 +-
airflow/providers/slack/operators/slack_webhook.py | 16 +-
airflow/providers/slack/transfers/sql_to_slack.py | 20 +-
airflow/providers/slack/utils/__init__.py | 4 +-
airflow/providers/snowflake/hooks/snowflake.py | 112 ++---
airflow/providers/snowflake/operators/snowflake.py | 40 +-
.../snowflake/transfers/copy_into_snowflake.py | 4 +-
.../snowflake/transfers/s3_to_snowflake.py | 4 +-
.../snowflake/transfers/snowflake_to_slack.py | 10 +-
airflow/providers/sqlite/hooks/sqlite.py | 10 +-
airflow/providers/sqlite/operators/sqlite.py | 10 +-
airflow/providers/ssh/hooks/ssh.py | 98 ++---
airflow/providers/ssh/operators/ssh.py | 22 +-
airflow/providers/tableau/hooks/tableau.py | 26 +-
airflow/providers/tableau/operators/tableau.py | 36 +-
.../tableau/operators/tableau_refresh_workbook.py | 10 +-
airflow/providers/tableau/sensors/tableau.py | 8 +-
airflow/providers/tabular/hooks/tabular.py | 6 +-
airflow/providers/telegram/hooks/telegram.py | 4 +-
airflow/providers/telegram/operators/telegram.py | 6 +-
airflow/providers/trino/hooks/trino.py | 94 ++---
airflow/providers/trino/operators/trino.py | 8 +-
airflow/providers/trino/transfers/gcs_to_trino.py | 6 +-
airflow/providers/vertica/hooks/vertica.py | 12 +-
airflow/providers/vertica/operators/vertica.py | 10 +-
airflow/providers/yandex/hooks/yandex.py | 66 +--
.../yandex/operators/yandexcloud_dataproc.py | 26 +-
airflow/providers/zendesk/hooks/zendesk.py | 10 +-
pyproject.toml | 1 -
488 files changed, 7830 insertions(+), 7823 deletions(-)
