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 bd9e8ce Fix Google Mypy Dataproc errors (#20570)
add d56e7b5 Fix template_fields type to have MyPy friendly Sequence type
(#20571)
No new revisions were added by this update.
Summary of changes:
airflow/providers/airbyte/operators/airbyte.py | 4 +-
airflow/providers/airbyte/sensors/airbyte.py | 4 +-
airflow/providers/alibaba/cloud/sensors/oss_key.py | 4 +-
airflow/providers/amazon/aws/operators/athena.py | 4 +-
airflow/providers/amazon/aws/operators/batch.py | 4 +-
.../amazon/aws/operators/cloud_formation.py | 6 +--
airflow/providers/amazon/aws/operators/datasync.py | 4 +-
airflow/providers/amazon/aws/operators/dms.py | 12 ++---
airflow/providers/amazon/aws/operators/ec2.py | 6 +--
airflow/providers/amazon/aws/operators/ecs.py | 4 +-
airflow/providers/amazon/aws/operators/eks.py | 33 ++++++------
airflow/providers/amazon/aws/operators/emr.py | 18 ++++---
airflow/providers/amazon/aws/operators/glacier.py | 4 +-
airflow/providers/amazon/aws/operators/glue.py | 4 +-
.../amazon/aws/operators/redshift_cluster.py | 6 +--
.../providers/amazon/aws/operators/redshift_sql.py | 4 +-
airflow/providers/amazon/aws/operators/s3.py | 27 ++++++----
.../providers/amazon/aws/operators/sagemaker.py | 4 +-
airflow/providers/amazon/aws/operators/sns.py | 4 +-
airflow/providers/amazon/aws/operators/sqs.py | 4 +-
.../amazon/aws/operators/step_function.py | 6 +--
airflow/providers/amazon/aws/sensors/athena.py | 4 +-
airflow/providers/amazon/aws/sensors/batch.py | 4 +-
.../amazon/aws/sensors/cloud_formation.py | 6 +--
airflow/providers/amazon/aws/sensors/dms.py | 6 +--
airflow/providers/amazon/aws/sensors/ec2.py | 4 +-
airflow/providers/amazon/aws/sensors/eks.py | 20 ++++++--
airflow/providers/amazon/aws/sensors/emr.py | 8 +--
airflow/providers/amazon/aws/sensors/glacier.py | 4 +-
airflow/providers/amazon/aws/sensors/glue.py | 4 +-
.../amazon/aws/sensors/glue_catalog_partition.py | 4 +-
.../amazon/aws/sensors/redshift_cluster.py | 4 +-
airflow/providers/amazon/aws/sensors/s3.py | 8 +--
airflow/providers/amazon/aws/sensors/sagemaker.py | 10 ++--
airflow/providers/amazon/aws/sensors/sqs.py | 4 +-
.../providers/amazon/aws/sensors/step_function.py | 4 +-
.../providers/amazon/aws/transfers/exasol_to_s3.py | 4 +-
.../providers/amazon/aws/transfers/ftp_to_s3.py | 4 +-
.../providers/amazon/aws/transfers/gcs_to_s3.py | 4 +-
.../amazon/aws/transfers/glacier_to_gcs.py | 2 +-
.../amazon/aws/transfers/google_api_to_s3.py | 2 +-
.../amazon/aws/transfers/hive_to_dynamodb.py | 4 +-
.../amazon/aws/transfers/imap_attachment_to_s3.py | 4 +-
.../providers/amazon/aws/transfers/local_to_s3.py | 4 +-
.../providers/amazon/aws/transfers/mongo_to_s3.py | 4 +-
.../providers/amazon/aws/transfers/mysql_to_s3.py | 4 +-
.../amazon/aws/transfers/redshift_to_s3.py | 11 +++-
.../providers/amazon/aws/transfers/s3_to_ftp.py | 4 +-
.../amazon/aws/transfers/s3_to_redshift.py | 4 +-
.../providers/amazon/aws/transfers/s3_to_sftp.py | 4 +-
.../amazon/aws/transfers/salesforce_to_s3.py | 4 +-
.../providers/amazon/aws/transfers/sftp_to_s3.py | 4 +-
airflow/providers/apache/beam/operators/beam.py | 14 +++--
.../providers/apache/cassandra/sensors/record.py | 4 +-
.../providers/apache/cassandra/sensors/table.py | 4 +-
airflow/providers/apache/drill/operators/drill.py | 4 +-
airflow/providers/apache/druid/operators/druid.py | 4 +-
.../apache/druid/transfers/hive_to_druid.py | 4 +-
airflow/providers/apache/hdfs/sensors/hdfs.py | 4 +-
airflow/providers/apache/hdfs/sensors/web_hdfs.py | 4 +-
airflow/providers/apache/hive/operators/hive.py | 4 +-
.../providers/apache/hive/operators/hive_stats.py | 4 +-
.../apache/hive/sensors/hive_partition.py | 4 +-
.../apache/hive/sensors/metastore_partition.py | 4 +-
.../apache/hive/sensors/named_hive_partition.py | 4 +-
.../apache/hive/transfers/hive_to_mysql.py | 4 +-
.../apache/hive/transfers/hive_to_samba.py | 4 +-
.../apache/hive/transfers/mssql_to_hive.py | 4 +-
.../apache/hive/transfers/mysql_to_hive.py | 4 +-
.../providers/apache/hive/transfers/s3_to_hive.py | 4 +-
.../apache/hive/transfers/vertica_to_hive.py | 4 +-
.../providers/apache/kylin/operators/kylin_cube.py | 4 +-
airflow/providers/apache/livy/operators/livy.py | 2 +-
airflow/providers/apache/livy/sensors/livy.py | 4 +-
airflow/providers/apache/pig/operators/pig.py | 4 +-
.../providers/apache/spark/operators/spark_sql.py | 4 +-
.../apache/spark/operators/spark_submit.py | 4 +-
airflow/providers/apache/sqoop/operators/sqoop.py | 4 +-
.../cncf/kubernetes/operators/kubernetes_pod.py | 4 +-
.../cncf/kubernetes/operators/spark_kubernetes.py | 4 +-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 4 +-
.../providers/databricks/operators/databricks.py | 6 +--
airflow/providers/dingding/operators/dingding.py | 4 +-
.../providers/discord/operators/discord_webhook.py | 4 +-
airflow/providers/docker/decorators/docker.py | 4 +-
airflow/providers/exasol/operators/exasol.py | 4 +-
airflow/providers/ftp/sensors/ftp.py | 4 +-
airflow/providers/google/ads/operators/ads.py | 2 +-
.../providers/google/ads/transfers/ads_to_gcs.py | 2 +-
airflow/providers/google/cloud/operators/automl.py | 26 +++++-----
.../providers/google/cloud/operators/bigquery.py | 36 ++++++-------
.../google/cloud/operators/bigquery_dts.py | 6 +--
.../providers/google/cloud/operators/bigtable.py | 24 ++++-----
.../google/cloud/operators/cloud_build.py | 22 ++++----
.../google/cloud/operators/cloud_memorystore.py | 44 +++++++++-------
.../providers/google/cloud/operators/cloud_sql.py | 18 +++----
.../operators/cloud_storage_transfer_service.py | 20 ++++----
.../providers/google/cloud/operators/compute.py | 10 ++--
.../google/cloud/operators/datacatalog.py | 42 +++++++--------
.../providers/google/cloud/operators/dataflow.py | 16 +++---
.../providers/google/cloud/operators/datafusion.py | 20 ++++----
.../providers/google/cloud/operators/dataprep.py | 8 +--
.../providers/google/cloud/operators/dataproc.py | 48 ++++++++---------
.../google/cloud/operators/dataproc_metastore.py | 20 ++++----
.../providers/google/cloud/operators/datastore.py | 22 ++++----
airflow/providers/google/cloud/operators/dlp.py | 60 +++++++++++-----------
.../providers/google/cloud/operators/functions.py | 6 +--
airflow/providers/google/cloud/operators/gcs.py | 20 ++++----
.../google/cloud/operators/kubernetes_engine.py | 8 +--
.../google/cloud/operators/life_sciences.py | 2 +-
.../providers/google/cloud/operators/mlengine.py | 48 ++++++++---------
.../google/cloud/operators/natural_language.py | 8 +--
airflow/providers/google/cloud/operators/pubsub.py | 24 ++++-----
.../providers/google/cloud/operators/spanner.py | 12 ++---
.../google/cloud/operators/speech_to_text.py | 2 +-
.../google/cloud/operators/stackdriver.py | 20 ++++----
airflow/providers/google/cloud/operators/tasks.py | 26 +++++-----
.../google/cloud/operators/text_to_speech.py | 2 +-
.../providers/google/cloud/operators/translate.py | 2 +-
.../google/cloud/operators/translate_speech.py | 2 +-
.../google/cloud/operators/video_intelligence.py | 6 +--
airflow/providers/google/cloud/operators/vision.py | 34 ++++++------
.../providers/google/cloud/operators/workflows.py | 18 +++----
airflow/providers/google/cloud/sensors/bigquery.py | 4 +-
.../providers/google/cloud/sensors/bigquery_dts.py | 2 +-
airflow/providers/google/cloud/sensors/bigtable.py | 4 +-
.../sensors/cloud_storage_transfer_service.py | 2 +-
airflow/providers/google/cloud/sensors/dataflow.py | 8 +--
.../providers/google/cloud/sensors/datafusion.py | 2 +-
airflow/providers/google/cloud/sensors/dataproc.py | 4 +-
airflow/providers/google/cloud/sensors/gcs.py | 8 +--
airflow/providers/google/cloud/sensors/pubsub.py | 4 +-
.../providers/google/cloud/sensors/workflows.py | 2 +-
.../cloud/transfers/azure_fileshare_to_gcs.py | 4 +-
.../google/cloud/transfers/bigquery_to_bigquery.py | 2 +-
.../google/cloud/transfers/bigquery_to_gcs.py | 2 +-
.../google/cloud/transfers/bigquery_to_mssql.py | 2 +-
.../google/cloud/transfers/bigquery_to_mysql.py | 2 +-
.../google/cloud/transfers/cassandra_to_gcs.py | 2 +-
.../google/cloud/transfers/facebook_ads_to_gcs.py | 2 +-
.../google/cloud/transfers/gcs_to_bigquery.py | 2 +-
.../providers/google/cloud/transfers/gcs_to_gcs.py | 2 +-
.../google/cloud/transfers/gcs_to_local.py | 2 +-
.../google/cloud/transfers/gcs_to_sftp.py | 2 +-
.../google/cloud/transfers/gdrive_to_gcs.py | 4 +-
.../google/cloud/transfers/gdrive_to_local.py | 4 +-
.../google/cloud/transfers/local_to_gcs.py | 2 +-
.../providers/google/cloud/transfers/s3_to_gcs.py | 4 +-
.../google/cloud/transfers/salesforce_to_gcs.py | 4 +-
.../google/cloud/transfers/sftp_to_gcs.py | 2 +-
.../google/cloud/transfers/sheets_to_gcs.py | 4 +-
.../providers/google/cloud/transfers/sql_to_gcs.py | 2 +-
.../google/firebase/operators/firestore.py | 2 +-
.../marketing_platform/operators/analytics.py | 12 ++---
.../operators/campaign_manager.py | 12 ++---
.../marketing_platform/operators/display_video.py | 16 +++---
.../marketing_platform/operators/search_ads.py | 4 +-
.../marketing_platform/sensors/campaign_manager.py | 2 +-
.../marketing_platform/sensors/display_video.py | 4 +-
.../marketing_platform/sensors/search_ads.py | 2 +-
airflow/providers/google/suite/operators/sheets.py | 4 +-
airflow/providers/google/suite/sensors/drive.py | 2 +-
.../google/suite/transfers/gcs_to_gdrive.py | 2 +-
.../google/suite/transfers/gcs_to_sheets.py | 4 +-
.../google/suite/transfers/sql_to_sheets.py | 2 +-
airflow/providers/grpc/operators/grpc.py | 4 +-
airflow/providers/http/operators/http.py | 6 +--
airflow/providers/http/sensors/http.py | 4 +-
airflow/providers/imap/sensors/imap_attachment.py | 4 +-
airflow/providers/influxdb/operators/influxdb.py | 4 +-
airflow/providers/jdbc/operators/jdbc.py | 4 +-
.../jenkins/operators/jenkins_job_trigger.py | 4 +-
airflow/providers/jira/operators/jira.py | 4 +-
airflow/providers/jira/sensors/jira.py | 4 +-
airflow/providers/microsoft/azure/operators/adx.py | 4 +-
.../providers/microsoft/azure/operators/batch.py | 4 +-
.../azure/operators/container_instances.py | 2 +-
.../providers/microsoft/azure/operators/cosmos.py | 4 +-
.../microsoft/azure/operators/data_factory.py | 4 +-
.../microsoft/azure/operators/wasb_delete_blob.py | 4 +-
.../providers/microsoft/azure/sensors/cosmos.py | 4 +-
.../microsoft/azure/sensors/data_factory.py | 9 +++-
airflow/providers/microsoft/azure/sensors/wasb.py | 6 +--
.../microsoft/azure/transfers/azure_blob_to_gcs.py | 2 +-
.../microsoft/azure/transfers/local_to_adls.py | 4 +-
.../microsoft/azure/transfers/local_to_wasb.py | 4 +-
.../azure/transfers/oracle_to_azure_data_lake.py | 4 +-
.../microsoft/azure/transfers/sftp_to_wasb.py | 4 +-
.../providers/microsoft/mssql/operators/mssql.py | 4 +-
airflow/providers/microsoft/psrp/operators/psrp.py | 4 +-
.../providers/microsoft/winrm/operators/winrm.py | 4 +-
airflow/providers/mongo/sensors/mongo.py | 4 +-
airflow/providers/mysql/operators/mysql.py | 4 +-
.../providers/mysql/transfers/presto_to_mysql.py | 4 +-
airflow/providers/mysql/transfers/s3_to_mysql.py | 4 +-
.../providers/mysql/transfers/trino_to_mysql.py | 4 +-
.../providers/mysql/transfers/vertica_to_mysql.py | 4 +-
airflow/providers/neo4j/operators/neo4j.py | 4 +-
airflow/providers/opsgenie/operators/opsgenie.py | 4 +-
airflow/providers/oracle/operators/oracle.py | 6 +--
.../providers/oracle/transfers/oracle_to_oracle.py | 4 +-
airflow/providers/papermill/operators/papermill.py | 4 +-
airflow/providers/postgres/operators/postgres.py | 4 +-
airflow/providers/qubole/operators/qubole.py | 4 +-
airflow/providers/qubole/operators/qubole_check.py | 6 +--
airflow/providers/qubole/sensors/qubole.py | 4 +-
airflow/providers/redis/operators/redis_publish.py | 4 +-
airflow/providers/redis/sensors/redis_key.py | 4 +-
airflow/providers/redis/sensors/redis_pub_sub.py | 4 +-
.../segment/operators/segment_track_event.py | 4 +-
airflow/providers/sftp/operators/sftp.py | 4 +-
airflow/providers/sftp/sensors/sftp.py | 4 +-
.../providers/singularity/operators/singularity.py | 4 +-
airflow/providers/slack/operators/slack.py | 6 +--
airflow/providers/slack/operators/slack_webhook.py | 6 +--
airflow/providers/snowflake/operators/snowflake.py | 6 +--
.../snowflake/transfers/s3_to_snowflake.py | 4 +-
.../snowflake/transfers/snowflake_to_slack.py | 4 +-
airflow/providers/sqlite/operators/sqlite.py | 4 +-
airflow/providers/ssh/operators/ssh.py | 4 +-
.../tableau/sensors/tableau_job_status.py | 4 +-
airflow/providers/telegram/operators/telegram.py | 4 +-
airflow/providers/vertica/operators/vertica.py | 4 +-
.../yandex/operators/yandexcloud_dataproc.py | 12 ++---
.../slack/operators/test_slack_webhook.py | 4 +-
225 files changed, 818 insertions(+), 766 deletions(-)
