This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch move-tests-common
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 5050fae8fd Move tests_common from "dev" to top-level.
add 7ae3a55194 Add early job_id xcom_push for google provider Beam
Pipeline operators (#42982)
add 72da8f6b60 Add logic to mark backfills as complete (#42683)
add baa87b600b fix mypy check failure on main (#42976)
add c5e4a74cfc mark
test_setup_constraint_mapped_task_upstream_removed_and_success as flaky (#42997)
add 85c2b7d722 Update providers metadata 2024-10-14 (#42995)
add 5316e618e0 Update json schema pre-commit to have draft7 schema in file
(#43005)
add b979debb51 AIP-84 Patch Variable (#42929)
add ced319fe95 Commit the session between writing and deletion of RTIF
(#42928)
add 2e5607a44c Refactor FastApi Dag and DagRun endpoints tests (#42949)
add 4122597347 Minor updates in UI contributing docs (#43013)
add 4c5ad9c846 AIP-84 post variable (#42948)
add 7c1f638e3d Move tests common without changes
add 14da4a1c6b Fix docstrings in tests_common
add a6b8ba23a5 Move tests_common from "dev" to top-level.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5050fae8fd)
\
N -- N -- N refs/heads/move-tests-common (a6b8ba23a5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.pre-commit-config.yaml | 4 +-
.../api_connexion/endpoints/variable_endpoint.py | 2 +
airflow/api_fastapi/openapi/v1-generated.yaml | 132 +++++-
airflow/api_fastapi/serializers/dags.py | 2 +-
airflow/api_fastapi/serializers/variables.py | 17 +-
airflow/api_fastapi/views/public/variables.py | 41 +-
airflow/jobs/scheduler_job_runner.py | 30 +-
airflow/models/dag.py | 1 +
airflow/models/taskinstance.py | 3 +-
airflow/ui/openapi-gen/queries/common.ts | 6 +
airflow/ui/openapi-gen/queries/queries.ts | 88 +++-
airflow/ui/openapi-gen/requests/schemas.gen.ts | 41 +-
airflow/ui/openapi-gen/requests/services.gen.ts | 62 +++
airflow/ui/openapi-gen/requests/types.gen.ts | 79 +++-
contributing-docs/14_node_environment_setup.rst | 4 +-
generated/provider_metadata.json | 358 ++++++++++------
helm_tests/airflow_aux/test_pod_template_file.py | 1 +
.../providers/apache/beam/operators/beam.py | 19 +-
providers/tests/apache/beam/operators/test_beam.py | 21 +
.../system/airbyte/example_airbyte_trigger_job.py | 6 -
.../system/alibaba/example_adb_spark_batch.py | 6 -
.../tests/system/alibaba/example_adb_spark_sql.py | 6 -
.../tests/system/alibaba/example_oss_bucket.py | 6 -
.../tests/system/alibaba/example_oss_object.py | 6 -
.../tests/system/amazon/aws/example_appflow.py | 6 -
.../tests/system/amazon/aws/example_appflow_run.py | 6 -
.../tests/system/amazon/aws/example_athena.py | 6 -
.../system/amazon/aws/example_azure_blob_to_s3.py | 6 -
providers/tests/system/amazon/aws/example_batch.py | 6 -
.../tests/system/amazon/aws/example_bedrock.py | 6 -
.../aws/example_bedrock_retrieve_and_generate.py | 6 -
.../system/amazon/aws/example_cloudformation.py | 6 -
.../tests/system/amazon/aws/example_comprehend.py | 6 -
.../aws/example_comprehend_document_classifier.py | 6 -
.../tests/system/amazon/aws/example_datasync.py | 6 -
providers/tests/system/amazon/aws/example_dms.py | 6 -
.../tests/system/amazon/aws/example_dynamodb.py | 6 -
.../system/amazon/aws/example_dynamodb_to_s3.py | 6 -
providers/tests/system/amazon/aws/example_ec2.py | 6 -
providers/tests/system/amazon/aws/example_ecs.py | 6 -
.../tests/system/amazon/aws/example_ecs_fargate.py | 6 -
.../system/amazon/aws/example_eks_templated.py | 6 -
.../aws/example_eks_with_fargate_in_one_step.py | 6 -
.../amazon/aws/example_eks_with_fargate_profile.py | 6 -
.../aws/example_eks_with_nodegroup_in_one_step.py | 6 -
.../amazon/aws/example_eks_with_nodegroups.py | 6 -
providers/tests/system/amazon/aws/example_emr.py | 6 -
.../tests/system/amazon/aws/example_emr_eks.py | 6 -
.../amazon/aws/example_emr_notebook_execution.py | 6 -
.../system/amazon/aws/example_emr_serverless.py | 6 -
.../tests/system/amazon/aws/example_eventbridge.py | 6 -
.../tests/system/amazon/aws/example_ftp_to_s3.py | 6 -
.../tests/system/amazon/aws/example_gcs_to_s3.py | 6 -
.../system/amazon/aws/example_glacier_to_gcs.py | 6 -
providers/tests/system/amazon/aws/example_glue.py | 6 -
.../system/amazon/aws/example_glue_data_quality.py | 6 -
...xample_glue_data_quality_with_recommendation.py | 6 -
.../system/amazon/aws/example_glue_databrew.py | 6 -
.../amazon/aws/example_google_api_sheets_to_s3.py | 6 -
.../amazon/aws/example_google_api_youtube_to_s3.py | 6 -
.../system/amazon/aws/example_hive_to_dynamodb.py | 6 -
.../tests/system/amazon/aws/example_http_to_s3.py | 6 -
.../amazon/aws/example_imap_attachment_to_s3.py | 6 -
.../system/amazon/aws/example_kinesis_analytics.py | 6 -
.../tests/system/amazon/aws/example_lambda.py | 6 -
.../tests/system/amazon/aws/example_local_to_s3.py | 6 -
.../tests/system/amazon/aws/example_mongo_to_s3.py | 6 -
.../tests/system/amazon/aws/example_neptune.py | 6 -
.../tests/system/amazon/aws/example_quicksight.py | 6 -
.../tests/system/amazon/aws/example_rds_event.py | 6 -
.../tests/system/amazon/aws/example_rds_export.py | 6 -
.../system/amazon/aws/example_rds_instance.py | 6 -
.../system/amazon/aws/example_rds_snapshot.py | 6 -
.../tests/system/amazon/aws/example_redshift.py | 6 -
.../amazon/aws/example_redshift_s3_transfers.py | 6 -
providers/tests/system/amazon/aws/example_s3.py | 6 -
.../system/amazon/aws/example_s3_to_dynamodb.py | 6 -
.../tests/system/amazon/aws/example_s3_to_ftp.py | 6 -
.../tests/system/amazon/aws/example_s3_to_sftp.py | 6 -
.../tests/system/amazon/aws/example_s3_to_sql.py | 6 -
.../tests/system/amazon/aws/example_sagemaker.py | 6 -
.../amazon/aws/example_sagemaker_endpoint.py | 6 -
.../amazon/aws/example_sagemaker_notebook.py | 6 -
.../amazon/aws/example_sagemaker_pipeline.py | 6 -
.../system/amazon/aws/example_salesforce_to_s3.py | 6 -
.../tests/system/amazon/aws/example_sftp_to_s3.py | 6 -
providers/tests/system/amazon/aws/example_sns.py | 6 -
.../tests/system/amazon/aws/example_sql_to_s3.py | 6 -
providers/tests/system/amazon/aws/example_sqs.py | 6 -
.../system/amazon/aws/example_step_functions.py | 6 -
.../apache/cassandra/example_cassandra_dag.py | 6 -
.../tests/system/apache/drill/example_drill_dag.py | 6 -
.../tests/system/apache/druid/example_druid_dag.py | 6 -
.../system/apache/hive/example_twitter_dag.py | 6 -
.../tests/system/apache/iceberg/example_iceberg.py | 6 -
.../apache/kafka/example_dag_event_listener.py | 6 -
.../system/apache/kafka/example_dag_hello_kafka.py | 6 -
.../tests/system/apache/kylin/example_kylin_dag.py | 6 -
providers/tests/system/apache/livy/example_livy.py | 6 -
providers/tests/system/apache/pig/example_pig.py | 6 -
.../tests/system/apache/spark/example_pyspark.py | 6 -
.../tests/system/apache/spark/example_spark_dag.py | 6 -
providers/tests/system/asana/example_asana.py | 6 -
.../system/cncf/kubernetes/example_kubernetes.py | 6 -
.../cncf/kubernetes/example_kubernetes_async.py | 6 -
.../cncf/kubernetes/example_kubernetes_job.py | 6 -
.../cncf/kubernetes/example_kubernetes_resource.py | 6 -
.../cncf/kubernetes/example_spark_kubernetes.py | 6 -
.../common/io/example_file_transfer_local_to_s3.py | 6 -
.../common/sql/example_sql_column_table_check.py | 6 -
.../system/common/sql/example_sql_execute_query.py | 6 -
.../tests/system/databricks/example_databricks.py | 6 -
.../system/databricks/example_databricks_repos.py | 6 -
.../databricks/example_databricks_sensors.py | 6 -
.../system/databricks/example_databricks_sql.py | 6 -
.../databricks/example_databricks_workflow.py | 6 -
.../tests/system/dbt/cloud/example_dbt_cloud.py | 6 -
.../tests/system/dingding/example_dingding.py | 6 -
providers/tests/system/docker/example_docker.py | 6 -
.../system/docker/example_docker_copy_data.py | 6 -
.../tests/system/docker/example_docker_swarm.py | 6 -
.../elasticsearch/example_elasticsearch_query.py | 6 -
providers/tests/system/ftp/example_ftp.py | 6 -
providers/tests/system/github/example_github.py | 6 -
providers/tests/system/google/ads/example_ads.py | 6 -
.../google/cloud/automl/example_automl_dataset.py | 6 -
.../cloud/automl/example_automl_translation.py | 6 -
.../automl/example_automl_video_classification.py | 6 -
.../cloud/automl/example_automl_video_tracking.py | 6 -
.../automl/example_automl_vision_classification.py | 6 -
.../example_automl_vision_object_detection.py | 6 -
.../cloud/azure/example_azure_blob_to_gcs.py | 6 -
.../cloud/azure/example_azure_fileshare_to_gcs.py | 6 -
.../cloud/bigquery/example_bigquery_dataset.py | 6 -
.../google/cloud/bigquery/example_bigquery_dts.py | 6 -
.../cloud/bigquery/example_bigquery_operations.py | 6 -
.../example_bigquery_operations_location.py | 6 -
.../bigquery/example_bigquery_queries_async.py | 6 -
.../cloud/bigquery/example_bigquery_sensors.py | 6 -
.../cloud/bigquery/example_bigquery_tables.py | 6 -
.../cloud/bigquery/example_bigquery_to_bigquery.py | 6 -
.../cloud/bigquery/example_bigquery_to_gcs.py | 6 -
.../bigquery/example_bigquery_to_gcs_async.py | 6 -
.../cloud/bigquery/example_bigquery_to_mssql.py | 6 -
.../cloud/bigquery/example_bigquery_to_mysql.py | 6 -
.../cloud/bigquery/example_bigquery_to_postgres.py | 6 -
.../cloud/bigquery/example_bigquery_transfer.py | 6 -
.../cloud/bigquery/example_bigquery_value_check.py | 6 -
.../google/cloud/bigtable/example_bigtable.py | 6 -
.../cloud/cloud_batch/example_cloud_batch.py | 6 -
.../cloud/cloud_build/example_cloud_build.py | 6 -
.../cloud_build/example_cloud_build_trigger.py | 6 -
.../cloud/cloud_functions/example_functions.py | 6 -
.../example_cloud_memorystore_memcached.py | 6 -
.../example_cloud_memorystore_redis.py | 6 -
.../google/cloud/cloud_run/example_cloud_run.py | 6 -
.../cloud/cloud_run/example_cloud_run_service.py | 6 -
.../google/cloud/cloud_sql/example_cloud_sql.py | 6 -
.../cloud/cloud_sql/example_cloud_sql_query.py | 6 -
.../cloud/cloud_sql/example_cloud_sql_query_ssl.py | 6 -
.../cloud/composer/example_cloud_composer.py | 6 -
.../system/google/cloud/compute/example_compute.py | 6 -
.../google/cloud/compute/example_compute_igm.py | 6 -
.../google/cloud/compute/example_compute_ssh.py | 6 -
.../cloud/compute/example_compute_ssh_os_login.py | 6 -
.../cloud/compute/example_compute_ssh_parallel.py | 6 -
.../example_dlp_deidentify_content.py | 6 -
.../data_loss_prevention/example_dlp_info_types.py | 6 -
.../example_dlp_inspect_template.py | 6 -
.../cloud/data_loss_prevention/example_dlp_job.py | 6 -
.../example_dlp_job_trigger.py | 6 -
.../google/cloud/dataflow/example_dataflow_go.py | 6 -
.../cloud/dataflow/example_dataflow_native_java.py | 6 -
.../dataflow/example_dataflow_native_python.py | 6 -
.../example_dataflow_native_python_async.py | 6 -
.../cloud/dataflow/example_dataflow_pipeline.py | 6 -
.../example_dataflow_sensors_deferrable.py | 6 -
.../google/cloud/dataflow/example_dataflow_sql.py | 6 -
.../dataflow/example_dataflow_streaming_python.py | 6 -
.../cloud/dataflow/example_dataflow_template.py | 6 -
.../google/cloud/dataflow/example_dataflow_yaml.py | 6 -
.../google/cloud/dataform/example_dataform.py | 6 -
.../google/cloud/datafusion/example_datafusion.py | 6 -
.../cloud/datapipelines/example_datapipeline.py | 6 -
.../google/cloud/dataplex/example_dataplex.py | 6 -
.../google/cloud/dataplex/example_dataplex_dp.py | 6 -
.../google/cloud/dataplex/example_dataplex_dq.py | 6 -
.../google/cloud/dataprep/example_dataprep.py | 6 -
.../cloud/dataproc/example_dataproc_batch.py | 6 -
.../dataproc/example_dataproc_batch_deferrable.py | 6 -
.../dataproc/example_dataproc_batch_persistent.py | 6 -
...proc_cluster_create_existing_stopped_cluster.py | 6 -
.../example_dataproc_cluster_deferrable.py | 6 -
.../dataproc/example_dataproc_cluster_diagnose.py | 6 -
.../dataproc/example_dataproc_cluster_generator.py | 6 -
.../example_dataproc_cluster_start_stop.py | 6 -
.../dataproc/example_dataproc_cluster_update.py | 6 -
.../cloud/dataproc/example_dataproc_flink.py | 6 -
.../google/cloud/dataproc/example_dataproc_gke.py | 6 -
.../cloud/dataproc/example_dataproc_hadoop.py | 6 -
.../google/cloud/dataproc/example_dataproc_hive.py | 6 -
.../google/cloud/dataproc/example_dataproc_pig.py | 6 -
.../cloud/dataproc/example_dataproc_presto.py | 6 -
.../cloud/dataproc/example_dataproc_pyspark.py | 6 -
.../cloud/dataproc/example_dataproc_spark.py | 6 -
.../cloud/dataproc/example_dataproc_spark_async.py | 6 -
.../dataproc/example_dataproc_spark_deferrable.py | 6 -
.../cloud/dataproc/example_dataproc_spark_sql.py | 6 -
.../cloud/dataproc/example_dataproc_sparkr.py | 6 -
.../cloud/dataproc/example_dataproc_trino.py | 6 -
.../cloud/dataproc/example_dataproc_workflow.py | 6 -
.../example_dataproc_workflow_deferrable.py | 6 -
.../example_dataproc_metastore.py | 6 -
.../example_dataproc_metastore_backup.py | 6 -
...ple_dataproc_metastore_hive_partition_sensor.py | 6 -
.../cloud/datastore/example_datastore_commit.py | 6 -
.../cloud/datastore/example_datastore_query.py | 6 -
.../cloud/datastore/example_datastore_rollback.py | 6 -
.../google/cloud/gcs/example_calendar_to_gcs.py | 6 -
.../system/google/cloud/gcs/example_firestore.py | 6 -
.../system/google/cloud/gcs/example_gcs_acl.py | 6 -
.../google/cloud/gcs/example_gcs_copy_delete.py | 6 -
.../system/google/cloud/gcs/example_gcs_sensor.py | 6 -
.../google/cloud/gcs/example_gcs_to_bigquery.py | 6 -
.../cloud/gcs/example_gcs_to_bigquery_async.py | 6 -
.../system/google/cloud/gcs/example_gcs_to_gcs.py | 6 -
.../google/cloud/gcs/example_gcs_to_gdrive.py | 6 -
.../google/cloud/gcs/example_gcs_to_sheets.py | 6 -
.../google/cloud/gcs/example_gcs_transform.py | 6 -
.../cloud/gcs/example_gcs_transform_timespan.py | 6 -
.../cloud/gcs/example_gcs_upload_download.py | 6 -
.../google/cloud/gcs/example_gdrive_to_gcs.py | 6 -
.../google/cloud/gcs/example_mssql_to_gcs.py | 6 -
.../google/cloud/gcs/example_mysql_to_gcs.py | 6 -
.../google/cloud/gcs/example_oracle_to_gcs.py | 6 -
.../system/google/cloud/gcs/example_s3_to_gcs.py | 6 -
.../system/google/cloud/gcs/example_sftp_to_gcs.py | 6 -
.../system/google/cloud/gcs/example_sheets.py | 6 -
.../google/cloud/gcs/example_sheets_to_gcs.py | 6 -
.../google/cloud/gcs/example_trino_to_gcs.py | 6 -
.../kubernetes_engine/example_kubernetes_engine.py | 6 -
.../example_kubernetes_engine_async.py | 6 -
.../example_kubernetes_engine_job.py | 6 -
.../example_kubernetes_engine_kueue.py | 6 -
.../example_kubernetes_engine_resource.py | 6 -
.../cloud/life_sciences/example_life_sciences.py | 6 -
.../google/cloud/ml_engine/example_mlengine.py | 6 -
.../natural_language/example_natural_language.py | 6 -
.../system/google/cloud/pubsub/example_pubsub.py | 6 -
.../cloud/pubsub/example_pubsub_deferrable.py | 6 -
.../system/google/cloud/spanner/example_spanner.py | 6 -
.../cloud/speech_to_text/example_speech_to_text.py | 6 -
.../cloud/sql_to_sheets/example_sql_to_sheets.py | 6 -
.../cloud/stackdriver/example_stackdriver.py | 6 -
.../example_cloud_storage_transfer_service_aws.py | 6 -
.../example_cloud_storage_transfer_service_gcp.py | 6 -
...le_cloud_storage_transfer_service_gcs_to_gcs.py | 6 -
.../system/google/cloud/tasks/example_queue.py | 6 -
.../system/google/cloud/tasks/example_tasks.py | 6 -
.../cloud/text_to_speech/example_text_to_speech.py | 6 -
.../google/cloud/transfers/example_gcs_to_sftp.py | 6 -
.../cloud/transfers/example_gdrive_to_local.py | 6 -
.../cloud/transfers/example_postgres_to_gcs.py | 6 -
.../google/cloud/translate/example_translate.py | 6 -
.../translate_speech/example_translate_speech.py | 6 -
...ample_vertex_ai_auto_ml_forecasting_training.py | 6 -
.../example_vertex_ai_auto_ml_image_training.py | 6 -
.../example_vertex_ai_auto_ml_list_training.py | 6 -
.../example_vertex_ai_auto_ml_tabular_training.py | 6 -
.../example_vertex_ai_auto_ml_video_training.py | 6 -
.../example_vertex_ai_batch_prediction_job.py | 6 -
.../example_vertex_ai_custom_container.py | 6 -
.../vertex_ai/example_vertex_ai_custom_job.py | 6 -
.../example_vertex_ai_custom_job_python_package.py | 6 -
.../cloud/vertex_ai/example_vertex_ai_dataset.py | 6 -
.../cloud/vertex_ai/example_vertex_ai_endpoint.py | 6 -
.../example_vertex_ai_generative_model.py | 6 -
.../example_vertex_ai_generative_model_tuning.py | 6 -
.../example_vertex_ai_hyperparameter_tuning_job.py | 6 -
.../example_vertex_ai_list_custom_jobs.py | 6 -
.../vertex_ai/example_vertex_ai_model_service.py | 6 -
.../vertex_ai/example_vertex_ai_pipeline_job.py | 6 -
.../example_video_intelligence.py | 6 -
.../cloud/vision/example_vision_annotate_image.py | 6 -
.../cloud/vision/example_vision_autogenerated.py | 6 -
.../google/cloud/vision/example_vision_explicit.py | 6 -
.../google/cloud/workflows/example_workflows.py | 6 -
.../datacatalog/example_datacatalog_entries.py | 6 -
.../example_datacatalog_search_catalog.py | 6 -
.../example_datacatalog_tag_templates.py | 6 -
.../google/datacatalog/example_datacatalog_tags.py | 6 -
.../tests/system/google/leveldb/example_leveldb.py | 6 -
.../marketing_platform/example_analytics_admin.py | 6 -
.../marketing_platform/example_campaign_manager.py | 6 -
.../marketing_platform/example_search_ads.py | 6 -
.../system/google/suite/example_local_to_drive.py | 6 -
providers/tests/system/http/example_http.py | 6 -
.../tests/system/influxdb/example_influxdb.py | 6 -
.../system/influxdb/example_influxdb_query.py | 6 -
.../tests/system/jdbc/example_jdbc_queries.py | 6 -
.../system/jenkins/example_jenkins_job_trigger.py | 6 -
.../microsoft/azure/example_adf_run_pipeline.py | 6 -
.../system/microsoft/azure/example_adls_create.py | 6 -
.../system/microsoft/azure/example_adls_delete.py | 6 -
.../system/microsoft/azure/example_adls_list.py | 6 -
.../azure/example_azure_batch_operator.py | 6 -
.../azure/example_azure_container_instances.py | 6 -
.../microsoft/azure/example_azure_cosmosdb.py | 6 -
.../microsoft/azure/example_azure_service_bus.py | 6 -
.../microsoft/azure/example_azure_synapse.py | 6 -
.../system/microsoft/azure/example_fileshare.py | 6 -
.../microsoft/azure/example_local_to_adls.py | 6 -
.../microsoft/azure/example_local_to_wasb.py | 6 -
.../system/microsoft/azure/example_msfabric.py | 6 -
.../system/microsoft/azure/example_msgraph.py | 6 -
.../system/microsoft/azure/example_powerbi.py | 6 -
.../azure/example_powerbi_dataset_refresh.py | 6 -
.../system/microsoft/azure/example_s3_to_wasb.py | 6 -
.../system/microsoft/azure/example_sftp_to_wasb.py | 6 -
.../azure/example_synapse_run_pipeline.py | 6 -
.../system/microsoft/azure/example_wasb_sensors.py | 6 -
.../tests/system/microsoft/mssql/example_mssql.py | 6 -
.../tests/system/microsoft/winrm/example_winrm.py | 6 -
providers/tests/system/mysql/example_mysql.py | 6 -
providers/tests/system/neo4j/example_neo4j.py | 6 -
providers/tests/system/openai/example_openai.py | 6 -
.../openai/example_trigger_batch_operator.py | 6 -
.../tests/system/opensearch/example_opensearch.py | 6 -
.../system/opsgenie/example_opsgenie_alert.py | 6 -
.../tests/system/papermill/example_papermill.py | 6 -
.../papermill/example_papermill_remote_verify.py | 6 -
.../system/papermill/example_papermill_verify.py | 6 -
.../tests/system/pgvector/example_pgvector.py | 6 -
.../system/pgvector/example_pgvector_openai.py | 6 -
.../system/pinecone/example_create_pod_index.py | 6 -
.../pinecone/example_create_serverless_index.py | 6 -
.../tests/system/pinecone/example_dag_pinecone.py | 6 -
.../system/pinecone/example_pinecone_cohere.py | 6 -
.../system/pinecone/example_pinecone_openai.py | 6 -
.../tests/system/postgres/example_postgres.py | 6 -
.../tests/system/presto/example_gcs_to_presto.py | 6 -
.../tests/system/redis/example_redis_publish.py | 6 -
providers/tests/system/salesforce/example_bulk.py | 6 -
.../salesforce/example_salesforce_apex_rest.py | 6 -
.../tests/system/samba/example_gcs_to_samba.py | 6 -
providers/tests/system/sftp/example_sftp_sensor.py | 6 -
.../system/singularity/example_singularity.py | 6 -
providers/tests/system/slack/example_slack.py | 6 -
.../tests/system/slack/example_slack_webhook.py | 6 -
.../tests/system/slack/example_sql_to_slack.py | 6 -
.../system/slack/example_sql_to_slack_webhook.py | 6 -
.../snowflake/example_copy_into_snowflake.py | 6 -
.../tests/system/snowflake/example_snowflake.py | 6 -
.../system/snowflake/example_snowpark_decorator.py | 6 -
.../system/snowflake/example_snowpark_operator.py | 6 -
providers/tests/system/sqlite/example_sqlite.py | 6 -
providers/tests/system/tableau/example_tableau.py | 6 -
.../tests/system/telegram/example_telegram.py | 6 -
.../example_azure_blob_to_teradata_transfer.py | 6 -
.../teradata/example_s3_to_teradata_transfer.py | 6 -
.../tests/system/teradata/example_ssl_teradata.py | 6 -
.../tests/system/teradata/example_teradata.py | 6 -
.../system/teradata/example_teradata_call_sp.py | 6 -
.../teradata/example_teradata_compute_cluster.py | 6 -
.../example_teradata_to_teradata_transfer.py | 6 -
.../tests/system/trino/example_gcs_to_trino.py | 6 -
providers/tests/system/trino/example_trino.py | 6 -
.../system/weaviate/example_weaviate_cohere.py | 6 -
.../example_weaviate_dynamic_mapping_dag.py | 6 -
.../system/weaviate/example_weaviate_openai.py | 6 -
.../system/weaviate/example_weaviate_operator.py | 6 -
.../system/weaviate/example_weaviate_using_hook.py | 6 -
.../weaviate/example_weaviate_vectorizer_dag.py | 6 -
.../example_weaviate_without_vectorizer_dag.py | 6 -
.../tests/system/yandex/example_yandexcloud.py | 6 -
.../system/yandex/example_yandexcloud_dataproc.py | 6 -
.../example_yandexcloud_dataproc_lightweight.py | 6 -
.../tests/system/yandex/example_yandexcloud_yq.py | 6 -
providers/tests/system/ydb/example_ydb.py | 6 -
.../system/zendesk/example_zendesk_custom_get.py | 6 -
pyproject.toml | 2 +-
scripts/ci/pre_commit/draft7_schema.json | 172 ++++++++
tests/api_fastapi/views/public/test_dag_run.py | 52 +--
tests/api_fastapi/views/public/test_dags.py | 477 +++++++++++----------
tests/api_fastapi/views/public/test_variables.py | 138 ++++++
tests/assets/test_manager.py | 1 +
tests/cli/commands/test_dag_command.py | 3 +-
tests/cli/commands/test_fastapi_api_command.py | 1 +
tests/cli/commands/test_internal_api_command.py | 3 +-
tests/cli/commands/test_plugins_command.py | 3 +-
tests/cli/commands/test_webserver_command.py | 3 +-
tests/core/test_configuration.py | 5 +-
tests/dag_processing/test_job_runner.py | 5 +-
.../test_external_task_sensor_check_existense.py | 1 +
tests/decorators/test_mapped.py | 1 +
tests/decorators/test_python.py | 3 +-
tests/jobs/test_base_job.py | 3 +-
tests/jobs/test_scheduler_job.py | 38 +-
tests/jobs/test_triggerer_job.py | 3 +-
tests/listeners/test_asset_listener.py | 1 +
tests/listeners/test_dag_import_error_listener.py | 3 +-
tests/listeners/test_listeners.py | 1 +
tests/models/test_baseoperator.py | 3 +-
tests/models/test_cleartasks.py | 3 +-
tests/models/test_dag.py | 15 +-
tests/models/test_dagbag.py | 5 +-
tests/models/test_dagrun.py | 3 +-
tests/models/test_mappedoperator.py | 3 +-
tests/models/test_renderedtifields.py | 50 ++-
tests/models/test_taskinstance.py | 3 +-
tests/plugins/test_plugin.py | 5 +-
tests/sensors/test_external_task_sensor.py | 3 +-
tests/sensors/test_python.py | 1 +
tests/serialization/test_pydantic_models.py | 3 +-
tests/serialization/test_serialized_objects.py | 1 +
.../task/task_runner/test_standard_task_runner.py | 5 +-
tests/ti_deps/deps/test_trigger_rule_dep.py | 1 +
tests/utils/test_dag_cycle.py | 1 +
tests/utils/test_file.py | 3 +-
tests/utils/test_state.py | 3 +-
tests/utils/test_task_group.py | 3 +-
tests/utils/test_types.py | 3 +-
tests/www/views/test_views_dagrun.py | 2 +-
tests_common/test_utils/__init__.py | 2 +-
424 files changed, 1494 insertions(+), 2623 deletions(-)
create mode 100644 scripts/ci/pre_commit/draft7_schema.json
