You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2021/04/12 12:08:39 UTC
[airflow] branch master updated (da780fc -> b477072)
This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from da780fc Fixes doc for SQSSensor (#15323)
add b477072 Add links to new modules for deprecated modules (#15316)
No new revisions were added by this update.
Summary of changes:
airflow/contrib/hooks/aws_athena_hook.py | 2 +-
airflow/contrib/hooks/aws_datasync_hook.py | 2 +-
airflow/contrib/hooks/aws_dynamodb_hook.py | 2 +-
airflow/contrib/hooks/aws_firehose_hook.py | 2 +-
airflow/contrib/hooks/aws_glue_catalog_hook.py | 2 +-
airflow/contrib/hooks/aws_hook.py | 7 +++++--
airflow/contrib/hooks/aws_lambda_hook.py | 5 ++++-
airflow/contrib/hooks/aws_logs_hook.py | 2 +-
airflow/contrib/hooks/aws_sns_hook.py | 2 +-
airflow/contrib/hooks/aws_sqs_hook.py | 2 +-
airflow/contrib/hooks/azure_container_instance_hook.py | 6 +++---
airflow/contrib/hooks/azure_container_volume_hook.py | 5 ++++-
airflow/contrib/hooks/azure_cosmos_hook.py | 2 +-
airflow/contrib/hooks/azure_data_lake_hook.py | 2 +-
airflow/contrib/hooks/azure_fileshare_hook.py | 2 +-
airflow/contrib/hooks/bigquery_hook.py | 2 +-
airflow/contrib/hooks/cassandra_hook.py | 2 +-
airflow/contrib/hooks/cloudant_hook.py | 2 +-
airflow/contrib/hooks/databricks_hook.py | 2 +-
airflow/contrib/hooks/datadog_hook.py | 2 +-
airflow/contrib/hooks/datastore_hook.py | 2 +-
airflow/contrib/hooks/dingding_hook.py | 2 +-
airflow/contrib/hooks/discord_webhook_hook.py | 2 +-
airflow/contrib/hooks/emr_hook.py | 2 +-
airflow/contrib/hooks/fs_hook.py | 2 +-
airflow/contrib/hooks/ftp_hook.py | 2 +-
airflow/contrib/hooks/gcp_api_base_hook.py | 2 +-
airflow/contrib/hooks/gcp_bigtable_hook.py | 2 +-
airflow/contrib/hooks/gcp_cloud_build_hook.py | 2 +-
airflow/contrib/hooks/gcp_compute_hook.py | 4 ++--
airflow/contrib/hooks/gcp_container_hook.py | 5 ++++-
airflow/contrib/hooks/gcp_dataflow_hook.py | 7 +++++--
airflow/contrib/hooks/gcp_dataproc_hook.py | 2 +-
airflow/contrib/hooks/gcp_dlp_hook.py | 2 +-
airflow/contrib/hooks/gcp_function_hook.py | 2 +-
airflow/contrib/hooks/gcp_kms_hook.py | 2 +-
airflow/contrib/hooks/gcp_mlengine_hook.py | 2 +-
airflow/contrib/hooks/gcp_natural_language_hook.py | 2 +-
airflow/contrib/hooks/gcp_pubsub_hook.py | 2 +-
airflow/contrib/hooks/gcp_spanner_hook.py | 2 +-
airflow/contrib/hooks/gcp_speech_to_text_hook.py | 2 +-
airflow/contrib/hooks/gcp_sql_hook.py | 2 +-
airflow/contrib/hooks/gcp_tasks_hook.py | 2 +-
airflow/contrib/hooks/gcp_text_to_speech_hook.py | 2 +-
airflow/contrib/hooks/gcp_translate_hook.py | 2 +-
airflow/contrib/hooks/gcp_video_intelligence_hook.py | 2 +-
airflow/contrib/hooks/gcp_vision_hook.py | 2 +-
airflow/contrib/hooks/gcs_hook.py | 2 +-
airflow/contrib/hooks/gdrive_hook.py | 2 +-
airflow/contrib/hooks/grpc_hook.py | 2 +-
airflow/contrib/hooks/imap_hook.py | 2 +-
airflow/contrib/hooks/jenkins_hook.py | 2 +-
airflow/contrib/hooks/jira_hook.py | 2 +-
airflow/contrib/hooks/mongo_hook.py | 2 +-
airflow/contrib/hooks/openfaas_hook.py | 2 +-
airflow/contrib/hooks/opsgenie_alert_hook.py | 2 +-
airflow/contrib/hooks/pagerduty_hook.py | 2 +-
airflow/contrib/hooks/pinot_hook.py | 2 +-
airflow/contrib/hooks/qubole_check_hook.py | 2 +-
airflow/contrib/hooks/qubole_hook.py | 2 +-
airflow/contrib/hooks/redis_hook.py | 2 +-
airflow/contrib/hooks/redshift_hook.py | 2 +-
airflow/contrib/hooks/sagemaker_hook.py | 2 +-
airflow/contrib/hooks/salesforce_hook.py | 2 +-
airflow/contrib/hooks/segment_hook.py | 2 +-
airflow/contrib/hooks/sftp_hook.py | 2 +-
airflow/contrib/hooks/slack_webhook_hook.py | 2 +-
airflow/contrib/hooks/snowflake_hook.py | 2 +-
airflow/contrib/hooks/spark_jdbc_hook.py | 2 +-
airflow/contrib/hooks/spark_sql_hook.py | 2 +-
airflow/contrib/hooks/spark_submit_hook.py | 2 +-
airflow/contrib/hooks/sqoop_hook.py | 2 +-
airflow/contrib/hooks/ssh_hook.py | 2 +-
airflow/contrib/hooks/vertica_hook.py | 2 +-
airflow/contrib/hooks/wasb_hook.py | 2 +-
airflow/contrib/hooks/winrm_hook.py | 2 +-
airflow/contrib/operators/adls_list_operator.py | 2 +-
airflow/contrib/operators/adls_to_gcs.py | 2 +-
airflow/contrib/operators/aws_athena_operator.py | 2 +-
airflow/contrib/operators/aws_sqs_publish_operator.py | 2 +-
airflow/contrib/operators/awsbatch_operator.py | 9 +++++----
airflow/contrib/operators/azure_cosmos_operator.py | 2 +-
airflow/contrib/operators/bigquery_check_operator.py | 2 +-
airflow/contrib/operators/bigquery_get_data.py | 2 +-
airflow/contrib/operators/bigquery_operator.py | 2 +-
airflow/contrib/operators/bigquery_table_delete_operator.py | 2 +-
airflow/contrib/operators/bigquery_to_bigquery.py | 5 ++++-
airflow/contrib/operators/bigquery_to_gcs.py | 2 +-
airflow/contrib/operators/bigquery_to_mysql_operator.py | 4 +++-
airflow/contrib/operators/cassandra_to_gcs.py | 5 ++++-
airflow/contrib/operators/databricks_operator.py | 2 +-
airflow/contrib/operators/dataflow_operator.py | 2 +-
airflow/contrib/operators/dataproc_operator.py | 2 +-
airflow/contrib/operators/datastore_export_operator.py | 2 +-
airflow/contrib/operators/datastore_import_operator.py | 2 +-
airflow/contrib/operators/dingding_operator.py | 2 +-
airflow/contrib/operators/discord_webhook_operator.py | 2 +-
airflow/contrib/operators/docker_swarm_operator.py | 2 +-
airflow/contrib/operators/druid_operator.py | 2 +-
airflow/contrib/operators/dynamodb_to_s3.py | 2 +-
airflow/contrib/operators/ecs_operator.py | 2 +-
airflow/contrib/operators/emr_add_steps_operator.py | 2 +-
airflow/contrib/operators/emr_create_job_flow_operator.py | 2 +-
.../contrib/operators/emr_terminate_job_flow_operator.py | 5 ++++-
airflow/contrib/operators/file_to_gcs.py | 2 +-
airflow/contrib/operators/file_to_wasb.py | 5 ++++-
airflow/contrib/operators/gcp_cloud_build_operator.py | 2 +-
airflow/contrib/operators/gcp_compute_operator.py | 2 +-
airflow/contrib/operators/gcp_container_operator.py | 5 ++++-
airflow/contrib/operators/gcp_dlp_operator.py | 2 +-
airflow/contrib/operators/gcp_function_operator.py | 2 +-
airflow/contrib/operators/gcp_natural_language_operator.py | 2 +-
airflow/contrib/operators/gcp_spanner_operator.py | 2 +-
airflow/contrib/operators/gcp_speech_to_text_operator.py | 2 +-
airflow/contrib/operators/gcp_sql_operator.py | 2 +-
airflow/contrib/operators/gcp_tasks_operator.py | 2 +-
airflow/contrib/operators/gcp_text_to_speech_operator.py | 2 +-
airflow/contrib/operators/gcp_translate_operator.py | 2 +-
airflow/contrib/operators/gcp_translate_speech_operator.py | 5 ++++-
.../contrib/operators/gcp_video_intelligence_operator.py | 5 ++++-
airflow/contrib/operators/gcp_vision_operator.py | 2 +-
airflow/contrib/operators/gcs_acl_operator.py | 2 +-
airflow/contrib/operators/gcs_delete_operator.py | 2 +-
airflow/contrib/operators/gcs_download_operator.py | 2 +-
airflow/contrib/operators/gcs_list_operator.py | 2 +-
airflow/contrib/operators/gcs_operator.py | 2 +-
airflow/contrib/operators/gcs_to_bq.py | 2 +-
airflow/contrib/operators/gcs_to_gcs.py | 2 +-
airflow/contrib/operators/gcs_to_gdrive_operator.py | 2 +-
airflow/contrib/operators/gcs_to_s3.py | 2 +-
airflow/contrib/operators/grpc_operator.py | 2 +-
airflow/contrib/operators/hive_to_dynamodb.py | 2 +-
airflow/contrib/operators/imap_attachment_to_s3_operator.py | 5 ++++-
airflow/contrib/operators/jenkins_job_trigger_operator.py | 2 +-
airflow/contrib/operators/jira_operator.py | 2 +-
airflow/contrib/operators/kubernetes_pod_operator.py | 5 ++++-
airflow/contrib/operators/mlengine_operator.py | 2 +-
airflow/contrib/operators/mongo_to_s3.py | 2 +-
airflow/contrib/operators/mssql_to_gcs.py | 2 +-
airflow/contrib/operators/mysql_to_gcs.py | 2 +-
airflow/contrib/operators/opsgenie_alert_operator.py | 2 +-
airflow/contrib/operators/oracle_to_oracle_transfer.py | 6 +++---
airflow/contrib/operators/postgres_to_gcs_operator.py | 2 +-
airflow/contrib/operators/pubsub_operator.py | 6 +++---
airflow/contrib/operators/qubole_check_operator.py | 2 +-
airflow/contrib/operators/qubole_operator.py | 2 +-
airflow/contrib/operators/redis_publish_operator.py | 2 +-
airflow/contrib/operators/s3_copy_object_operator.py | 2 +-
airflow/contrib/operators/s3_delete_objects_operator.py | 5 ++++-
airflow/contrib/operators/s3_list_operator.py | 2 +-
airflow/contrib/operators/s3_to_gcs_operator.py | 2 +-
airflow/contrib/operators/s3_to_sftp_operator.py | 2 +-
airflow/contrib/operators/sagemaker_base_operator.py | 2 +-
airflow/contrib/operators/sagemaker_endpoint_operator.py | 5 ++++-
airflow/contrib/operators/sagemaker_model_operator.py | 2 +-
airflow/contrib/operators/sagemaker_training_operator.py | 2 +-
airflow/contrib/operators/sagemaker_transform_operator.py | 2 +-
airflow/contrib/operators/sagemaker_tuning_operator.py | 2 +-
airflow/contrib/operators/segment_track_event_operator.py | 2 +-
airflow/contrib/operators/sftp_operator.py | 2 +-
airflow/contrib/operators/sftp_to_s3_operator.py | 2 +-
airflow/contrib/operators/slack_webhook_operator.py | 2 +-
airflow/contrib/operators/snowflake_operator.py | 2 +-
airflow/contrib/operators/sns_publish_operator.py | 2 +-
airflow/contrib/operators/spark_jdbc_operator.py | 2 +-
airflow/contrib/operators/spark_sql_operator.py | 2 +-
airflow/contrib/operators/spark_submit_operator.py | 2 +-
airflow/contrib/operators/sql_to_gcs.py | 2 +-
airflow/contrib/operators/sqoop_operator.py | 2 +-
airflow/contrib/operators/ssh_operator.py | 2 +-
airflow/contrib/operators/vertica_operator.py | 2 +-
airflow/contrib/operators/vertica_to_hive.py | 6 +++---
airflow/contrib/operators/vertica_to_mysql.py | 6 +++---
airflow/contrib/operators/wasb_delete_blob_operator.py | 5 ++++-
airflow/contrib/operators/winrm_operator.py | 2 +-
airflow/contrib/secrets/aws_secrets_manager.py | 2 +-
airflow/contrib/secrets/aws_systems_manager.py | 2 +-
airflow/contrib/secrets/azure_key_vault.py | 2 +-
airflow/contrib/secrets/gcp_secrets_manager.py | 2 +-
airflow/contrib/secrets/hashicorp_vault.py | 2 +-
airflow/contrib/sensors/aws_athena_sensor.py | 2 +-
.../contrib/sensors/aws_glue_catalog_partition_sensor.py | 5 ++++-
airflow/contrib/sensors/aws_redshift_cluster_sensor.py | 2 +-
airflow/contrib/sensors/aws_sqs_sensor.py | 2 +-
airflow/contrib/sensors/azure_cosmos_sensor.py | 2 +-
airflow/contrib/sensors/bash_sensor.py | 2 +-
airflow/contrib/sensors/bigquery_sensor.py | 2 +-
airflow/contrib/sensors/cassandra_record_sensor.py | 2 +-
airflow/contrib/sensors/cassandra_table_sensor.py | 2 +-
airflow/contrib/sensors/celery_queue_sensor.py | 2 +-
airflow/contrib/sensors/datadog_sensor.py | 2 +-
airflow/contrib/sensors/emr_base_sensor.py | 2 +-
airflow/contrib/sensors/emr_job_flow_sensor.py | 2 +-
airflow/contrib/sensors/emr_step_sensor.py | 2 +-
airflow/contrib/sensors/file_sensor.py | 2 +-
airflow/contrib/sensors/ftp_sensor.py | 2 +-
airflow/contrib/sensors/gcp_transfer_sensor.py | 6 +++---
airflow/contrib/sensors/gcs_sensor.py | 2 +-
airflow/contrib/sensors/hdfs_sensor.py | 6 +++---
airflow/contrib/sensors/imap_attachment_sensor.py | 2 +-
airflow/contrib/sensors/jira_sensor.py | 2 +-
airflow/contrib/sensors/mongo_sensor.py | 2 +-
airflow/contrib/sensors/pubsub_sensor.py | 2 +-
airflow/contrib/sensors/python_sensor.py | 2 +-
airflow/contrib/sensors/qubole_sensor.py | 2 +-
airflow/contrib/sensors/redis_key_sensor.py | 2 +-
airflow/contrib/sensors/redis_pub_sub_sensor.py | 2 +-
airflow/contrib/sensors/sagemaker_base_sensor.py | 2 +-
airflow/contrib/sensors/sagemaker_endpoint_sensor.py | 2 +-
airflow/contrib/sensors/sagemaker_training_sensor.py | 2 +-
airflow/contrib/sensors/sagemaker_transform_sensor.py | 2 +-
airflow/contrib/sensors/sagemaker_tuning_sensor.py | 2 +-
airflow/contrib/sensors/sftp_sensor.py | 2 +-
airflow/contrib/sensors/wasb_sensor.py | 2 +-
airflow/contrib/sensors/weekday_sensor.py | 2 +-
airflow/contrib/task_runner/cgroup_task_runner.py | 2 +-
airflow/contrib/utils/gcp_field_sanitizer.py | 2 +-
airflow/contrib/utils/gcp_field_validator.py | 2 +-
.../contrib/utils/log/task_handler_with_custom_formatter.py | 2 +-
airflow/contrib/utils/mlengine_operator_utils.py | 5 ++++-
airflow/contrib/utils/mlengine_prediction_summary.py | 6 +++---
airflow/contrib/utils/weekday.py | 2 +-
airflow/hooks/S3_hook.py | 2 +-
airflow/hooks/base_hook.py | 2 +-
airflow/hooks/dbapi_hook.py | 2 +-
airflow/hooks/docker_hook.py | 2 +-
airflow/hooks/druid_hook.py | 2 +-
airflow/hooks/hdfs_hook.py | 2 +-
airflow/hooks/hive_hooks.py | 2 +-
airflow/hooks/http_hook.py | 2 +-
airflow/hooks/jdbc_hook.py | 2 +-
airflow/hooks/mssql_hook.py | 2 +-
airflow/hooks/mysql_hook.py | 2 +-
airflow/hooks/oracle_hook.py | 2 +-
airflow/hooks/pig_hook.py | 2 +-
airflow/hooks/postgres_hook.py | 2 +-
airflow/hooks/presto_hook.py | 2 +-
airflow/hooks/samba_hook.py | 2 +-
airflow/hooks/slack_hook.py | 2 +-
airflow/hooks/sqlite_hook.py | 2 +-
airflow/hooks/webhdfs_hook.py | 2 +-
airflow/hooks/zendesk_hook.py | 2 +-
airflow/kubernetes/pod.py | 5 ++++-
airflow/kubernetes/pod_launcher.py | 5 ++++-
airflow/kubernetes/pod_launcher_deprecated.py | 2 +-
airflow/kubernetes/pod_runtime_info_env.py | 2 +-
airflow/kubernetes/volume.py | 2 +-
airflow/kubernetes/volume_mount.py | 2 +-
airflow/operators/bash_operator.py | 2 +-
airflow/operators/branch_operator.py | 2 +-
airflow/operators/check_operator.py | 2 +-
airflow/operators/dagrun_operator.py | 2 +-
airflow/operators/docker_operator.py | 2 +-
airflow/operators/druid_check_operator.py | 2 +-
airflow/operators/dummy_operator.py | 2 +-
airflow/operators/email_operator.py | 2 +-
airflow/operators/gcs_to_s3.py | 2 +-
airflow/operators/google_api_to_s3_transfer.py | 4 ++--
airflow/operators/hive_operator.py | 2 +-
airflow/operators/hive_stats_operator.py | 2 +-
airflow/operators/hive_to_druid.py | 6 +++---
airflow/operators/hive_to_mysql.py | 4 ++--
airflow/operators/hive_to_samba_operator.py | 2 +-
airflow/operators/http_operator.py | 2 +-
airflow/operators/jdbc_operator.py | 2 +-
airflow/operators/latest_only_operator.py | 2 +-
airflow/operators/mssql_operator.py | 2 +-
airflow/operators/mssql_to_hive.py | 6 +++---
airflow/operators/mysql_operator.py | 2 +-
airflow/operators/mysql_to_hive.py | 2 +-
airflow/operators/oracle_operator.py | 2 +-
airflow/operators/papermill_operator.py | 2 +-
airflow/operators/pig_operator.py | 2 +-
airflow/operators/postgres_operator.py | 2 +-
airflow/operators/presto_check_operator.py | 2 +-
airflow/operators/presto_to_mysql.py | 6 +++---
airflow/operators/python_operator.py | 2 +-
airflow/operators/redshift_to_s3_operator.py | 13 ++++++-------
airflow/operators/s3_file_transform_operator.py | 5 ++++-
airflow/operators/s3_to_hive_operator.py | 2 +-
airflow/operators/s3_to_redshift_operator.py | 6 +++---
airflow/operators/slack_operator.py | 2 +-
airflow/operators/sql_branch_operator.py | 4 ++--
airflow/operators/sqlite_operator.py | 2 +-
airflow/operators/subdag_operator.py | 2 +-
airflow/providers/amazon/aws/hooks/aws_dynamodb.py | 2 +-
airflow/providers/cncf/kubernetes/backcompat/volume.py | 2 +-
airflow/sensors/base_sensor_operator.py | 2 +-
airflow/sensors/date_time_sensor.py | 2 +-
airflow/sensors/external_task_sensor.py | 2 +-
airflow/sensors/hdfs_sensor.py | 2 +-
airflow/sensors/hive_partition_sensor.py | 2 +-
airflow/sensors/http_sensor.py | 2 +-
airflow/sensors/metastore_partition_sensor.py | 5 ++++-
airflow/sensors/named_hive_partition_sensor.py | 2 +-
airflow/sensors/s3_key_sensor.py | 2 +-
airflow/sensors/s3_prefix_sensor.py | 2 +-
airflow/sensors/sql_sensor.py | 2 +-
airflow/sensors/time_delta_sensor.py | 2 +-
airflow/sensors/web_hdfs_sensor.py | 2 +-
airflow/utils/log/cloudwatch_task_handler.py | 2 +-
airflow/utils/log/es_task_handler.py | 2 +-
airflow/utils/log/gcs_task_handler.py | 2 +-
airflow/utils/log/s3_task_handler.py | 2 +-
airflow/utils/log/stackdriver_task_handler.py | 5 ++++-
airflow/utils/log/wasb_task_handler.py | 2 +-
306 files changed, 419 insertions(+), 345 deletions(-)