This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a change to branch v2-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 21b3f7c67e Field Deletion Warning when editing Connections (#41144)
(#41504)
add a9c7d1a057 [Backport] Deprecate implicit default DAG schedule (#41469)
No new revisions were added by this update.
Summary of changes:
.../example_dags/example_dynamic_task_mapping.py | 2 +-
...amic_task_mapping_with_no_taskflow_operators.py | 1 +
airflow/example_dags/example_setup_teardown.py | 1 +
.../example_setup_teardown_taskflow.py | 1 +
.../example_short_circuit_decorator.py | 2 +-
.../example_dags/example_short_circuit_operator.py | 1 +
airflow/example_dags/example_skip_dag.py | 2 +
airflow/example_dags/example_task_group.py | 1 +
.../example_dags/example_task_group_decorator.py | 1 +
airflow/models/dag.py | 8 +-
airflow/serialization/serialized_objects.py | 2 +-
kubernetes_tests/test_kubernetes_pod_operator.py | 2 +-
tests/api_connexion/endpoints/test_dag_endpoint.py | 37 +-
.../endpoints/test_extra_link_endpoint.py | 2 +-
tests/api_connexion/endpoints/test_log_endpoint.py | 2 +-
.../api_connexion/endpoints/test_task_endpoint.py | 4 +-
tests/api_connexion/schemas/test_dag_schema.py | 3 +-
tests/api_experimental/common/test_delete_dag.py | 6 +-
tests/api_experimental/common/test_trigger_dag.py | 16 +-
tests/callbacks/test_callback_requests.py | 5 +-
tests/conftest.py | 8 +
tests/dag_processing/test_job_runner.py | 13 +-
tests/dags/test_cli_triggered_dags.py | 4 +-
tests/dags/test_dagrun_fast_follow.py | 2 +-
tests/dags/test_default_impersonation.py | 2 +-
tests/dags/test_double_trigger.py | 2 +-
.../test_external_task_sensor_check_existense.py | 12 +-
tests/dags/test_heartbeat_failed_fast.py | 2 +-
tests/dags/test_impersonation.py | 2 +-
tests/dags/test_impersonation_subdag.py | 4 +-
tests/dags/test_issue_1225.py | 42 ++-
tests/dags/test_latest_runs.py | 2 +-
tests/dags/test_mapped_classic.py | 2 +-
tests/dags/test_mapped_taskflow.py | 6 +-
tests/dags/test_mark_state.py | 2 +-
tests/dags/test_no_impersonation.py | 2 +-
tests/dags/test_on_failure_callback.py | 2 +-
tests/dags/test_on_kill.py | 2 +-
tests/dags/test_parsing_context.py | 2 +-
tests/dags/test_prev_dagrun_dep.py | 6 +-
tests/dags/test_scheduler_dags.py | 12 +-
tests/dags/test_task_view_type_check.py | 2 +-
tests/dags/test_zip.zip | Bin 2285 -> 1999 bytes
tests/dags_corrupted/test_impersonation_custom.py | 4 +-
tests/dags_with_system_exit/a_system_exit.py | 4 +-
.../dags_with_system_exit/b_test_scheduler_dags.py | 4 +-
tests/dags_with_system_exit/c_system_exit.py | 4 +-
tests/decorators/test_mapped.py | 2 +-
tests/decorators/test_python.py | 4 +-
tests/decorators/test_task_group.py | 16 +-
.../integration/executors/test_celery_executor.py | 10 +-
.../redis/operators/test_redis_publish.py | 2 +-
tests/jobs/test_triggerer_job.py | 2 +-
tests/models/test_baseoperator.py | 48 ++-
tests/models/test_cleartasks.py | 1 +
tests/models/test_dag.py | 402 ++++++++++-----------
tests/models/test_dagbag.py | 42 ++-
tests/models/test_dagrun.py | 82 ++++-
tests/models/test_mappedoperator.py | 16 +-
tests/models/test_serialized_dag.py | 6 +-
tests/models/test_taskinstance.py | 2 +-
tests/operators/test_generic_transfer.py | 2 +-
tests/operators/test_subdag_operator.py | 40 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 2 +-
.../amazon/aws/log/test_s3_task_handler.py | 2 +-
.../amazon/aws/operators/test_cloud_formation.py | 4 +-
.../amazon/aws/operators/test_emr_add_steps.py | 13 +-
.../aws/operators/test_emr_create_job_flow.py | 1 +
.../aws/operators/test_emr_modify_cluster.py | 2 +-
tests/providers/amazon/aws/operators/test_rds.py | 72 +++-
.../amazon/aws/operators/test_sagemaker_base.py | 2 +-
tests/providers/amazon/aws/sensors/test_rds.py | 24 +-
tests/providers/amazon/aws/sensors/test_s3.py | 4 +-
tests/providers/amazon/aws/transfers/test_base.py | 2 +-
.../amazon/aws/transfers/test_dynamodb_to_s3.py | 2 +-
.../amazon/aws/transfers/test_hive_to_dynamodb.py | 2 +-
.../amazon/aws/transfers/test_http_to_s3.py | 2 +-
.../amazon/aws/transfers/test_local_to_s3.py | 2 +-
.../amazon/aws/transfers/test_mongo_to_s3.py | 2 +-
.../apache/druid/transfers/test_hive_to_druid.py | 2 +-
.../flink/operators/test_flink_kubernetes.py | 2 +-
.../apache/flink/sensors/test_flink_kubernetes.py | 2 +-
tests/providers/apache/hive/__init__.py | 2 +-
tests/providers/apache/hive/hooks/test_hive.py | 2 +-
.../hive/sensors/test_named_hive_partition.py | 2 +-
.../apache/hive/transfers/test_vertica_to_hive.py | 2 +-
.../apache/kylin/operators/test_kylin_cube.py | 2 +-
tests/providers/apache/livy/operators/test_livy.py | 2 +-
tests/providers/apache/livy/sensors/test_livy.py | 2 +-
.../apache/spark/operators/test_spark_jdbc.py | 2 +-
.../apache/spark/operators/test_spark_sql.py | 2 +-
.../apache/spark/operators/test_spark_submit.py | 2 +-
tests/providers/arangodb/sensors/test_arangodb.py | 2 +-
.../providers/asana/operators/test_asana_tasks.py | 3 +-
.../celery/executors/test_celery_executor.py | 6 +-
.../cncf/kubernetes/operators/test_job.py | 4 +-
.../cncf/kubernetes/operators/test_pod.py | 7 +-
.../cncf/kubernetes/operators/test_resource.py | 2 +-
.../kubernetes/operators/test_spark_kubernetes.py | 6 +-
.../kubernetes/sensors/test_spark_kubernetes.py | 2 +-
tests/providers/common/sql/operators/test_sql.py | 13 +-
tests/providers/common/sql/sensors/test_sql.py | 2 +-
.../databricks/operators/test_databricks.py | 8 +-
.../operators/test_databricks_workflow.py | 6 +-
.../sensors/test_databricks_partition.py | 2 +-
.../databricks/sensors/test_databricks_sql.py | 2 +-
tests/providers/dbt/cloud/operators/test_dbt.py | 6 +-
.../providers/dingding/operators/test_dingding.py | 2 +-
.../discord/operators/test_discord_webhook.py | 2 +-
tests/providers/docker/decorators/test_docker.py | 2 +-
tests/providers/fab/auth_manager/test_security.py | 4 +-
tests/providers/ftp/operators/test_ftp.py | 10 +-
tests/providers/github/operators/test_github.py | 2 +-
tests/providers/github/sensors/test_github.py | 2 +-
.../google/cloud/operators/test_cloud_build.py | 2 +-
.../google/cloud/operators/test_dataproc.py | 6 +-
.../google/cloud/operators/test_mlengine.py | 2 +-
.../google/cloud/transfers/test_gcs_to_bigquery.py | 2 +-
.../google/cloud/transfers/test_local_to_gcs.py | 2 +-
tests/providers/http/sensors/test_http.py | 2 +-
.../microsoft/azure/operators/test_data_factory.py | 2 +-
.../azure/operators/test_wasb_delete_blob.py | 2 +-
.../providers/microsoft/azure/sensors/test_wasb.py | 8 +-
.../azure/transfers/test_local_to_wasb.py | 2 +-
tests/providers/mysql/hooks/test_mysql.py | 2 +-
tests/providers/mysql/operators/test_mysql.py | 9 +-
.../mysql/transfers/test_presto_to_mysql.py | 2 +-
.../mysql/transfers/test_trino_to_mysql.py | 2 +-
.../mysql/transfers/test_vertica_to_mysql.py | 2 +-
.../providers/openlineage/plugins/test_adapter.py | 11 +-
.../providers/openlineage/plugins/test_listener.py | 3 +
.../openlineage/utils/test_selective_enable.py | 4 +-
tests/providers/openlineage/utils/test_utils.py | 44 ++-
.../providers/opsgenie/operators/test_opsgenie.py | 6 +-
.../providers/pinecone/operators/test_pinecone.py | 2 +-
.../providers/postgres/operators/test_postgres.py | 4 +-
.../providers/redis/log/test_redis_task_handler.py | 2 +-
.../redis/operators/test_redis_publish.py | 2 +-
tests/providers/redis/sensors/test_redis_key.py | 2 +-
.../providers/redis/sensors/test_redis_pub_sub.py | 2 +-
tests/providers/sftp/operators/test_sftp.py | 12 +-
.../slack/transfers/test_sql_to_slack_webhook.py | 2 +-
.../snowflake/operators/test_snowflake.py | 4 +-
tests/providers/sqlite/operators/test_sqlite.py | 2 +-
tests/sensors/test_bash.py | 2 +-
tests/sensors/test_date_time.py | 2 +-
tests/sensors/test_external_task_sensor.py | 10 +-
tests/sensors/test_filesystem.py | 3 +-
tests/sensors/test_time_delta.py | 4 +-
tests/sensors/test_time_sensor.py | 13 +-
tests/sensors/test_weekday_sensor.py | 4 +-
tests/serialization/test_dag_serialization.py | 90 +++--
.../providers/alibaba/example_adb_spark_batch.py | 1 +
.../providers/alibaba/example_adb_spark_sql.py | 1 +
.../system/providers/alibaba/example_oss_bucket.py | 1 +
.../system/providers/alibaba/example_oss_object.py | 1 +
.../apache/kafka/example_dag_event_listener.py | 1 +
.../databricks/example_databricks_workflow.py | 2 +-
tests/system/providers/github/example_github.py | 1 +
.../cloud/cloud_sql/example_cloud_sql_query.py | 1 +
.../cloud/cloud_sql/example_cloud_sql_query_ssl.py | 1 +
.../cloud/compute/example_compute_ssh_os_login.py | 2 +-
.../cloud/compute/example_compute_ssh_parallel.py | 2 +-
.../google/cloud/dataflow/example_dataflow_sql.py | 1 +
.../google/cloud/datafusion/example_datafusion.py | 1 +
.../example_cloud_storage_transfer_service_aws.py | 1 +
tests/system/providers/http/example_http.py | 1 +
.../providers/influxdb/example_influxdb_query.py | 1 +
.../azure/example_azure_batch_operator.py | 1 +
.../microsoft/azure/example_azure_cosmosdb.py | 1 +
.../microsoft/azure/example_wasb_sensors.py | 1 +
tests/system/providers/mysql/example_mysql.py | 1 +
tests/system/providers/neo4j/example_neo4j.py | 1 +
.../opsgenie/example_opsgenie_notifier.py | 1 +
.../providers/redis/example_redis_publish.py | 1 +
.../system/providers/telegram/example_telegram.py | 2 +-
tests/template/test_templater.py | 2 +-
tests/ti_deps/deps/test_dagrun_exists_dep.py | 2 +-
tests/ti_deps/deps/test_prev_dagrun_dep.py | 9 +-
tests/ti_deps/deps/test_task_concurrency.py | 2 +-
tests/triggers/test_external_task.py | 4 +-
tests/utils/test_dag_cycle.py | 18 +-
tests/utils/test_dot_renderer.py | 6 +-
tests/utils/test_edgemodifier.py | 8 +-
tests/utils/test_log_handlers.py | 8 +-
tests/utils/test_sqlalchemy.py | 7 +-
tests/utils/test_state.py | 4 +-
tests/utils/test_task_group.py | 103 ++++--
tests/utils/test_types.py | 4 +-
tests/www/views/test_views.py | 4 +-
tests/www/views/test_views_extra_links.py | 2 +-
tests/www/views/test_views_home.py | 12 +-
tests/www/views/test_views_rendered.py | 1 +
tests/www/views/test_views_tasks.py | 4 +-
194 files changed, 1022 insertions(+), 667 deletions(-)
