This is an automated email from the ASF dual-hosted git repository.
dimberman pushed a change to branch handle-stuck-in-queue
in repository https://gitbox.apache.org/repos/asf/airflow.git
from e232c18ff64 Merge branch 'handle-stuck-in-queue' of
https://github.com/apache/airflow into handle-stuck-in-queue
add d592338eab5 Bump happy-dom from 15.10.1 to 15.10.2 in /airflow/ui
(#43765)
add df46f316b5c Bumping epoch of cache for our dependencies (#43770)
add c83e72a4a6c Fix pickyness of google.auth 2.36.0 for mocks (#43771)
add 845a1605762 Note in pytest_plugin to not global import Airflow (#43738)
add a51487d89ab Remove AIRFLOW_V_2_8_PLUS for provider's compatibility
tests (#43763)
add 457e5273127 Correcting the wildcard character for _SearchParam (#43780)
add cb23472e41b AIP-65: Add back DAG versioning support (#43735)
add 31b10011f64 AIP-84 List Mapped Task Instances (#43642)
add c9d0dbf11d5 Extract OTEL span set attrs logic in one place in the
scheduler (#43787)
add e5020656300 AIP-84 List Task Instances (#43760)
add c63cc69323d AIP-84 Get TI and Mapped TI dependencies (#43788)
add f52c471ed3a AIP-72: Add "Get Connection" endpoint for Execution API
(#43767)
add 5be717cdf65 AIP-82 Create references between triggers and assets
(#43666)
add 24b2369ffe8 Generate `openapi.json` for the Execution API sub-app
(#43796)
add 0935be1448b Merge branch 'main' of https://github.com/apache/airflow
into handle-stuck-in-queue
No new revisions were added by this update.
Summary of changes:
Dockerfile.ci | 2 +-
airflow/api/common/trigger_dag.py | 5 +-
.../api_connexion/endpoints/dag_run_endpoint.py | 5 +-
.../endpoints/task_instance_endpoint.py | 3 +
airflow/api_fastapi/common/parameters.py | 153 +-
.../api_fastapi/core_api/openapi/v1-generated.yaml | 565 +++
.../core_api/routes/public/task_instances.py | 249 +-
.../core_api/serializers/task_instances.py | 13 +
airflow/api_fastapi/execution_api/app.py | 1 -
.../api_fastapi/execution_api/routes/__init__.py | 2 +
.../execution_api/routes/connections.py | 88 +
airflow/api_fastapi/execution_api/schemas.py | 20 +
airflow/dag_processing/manager.py | 15 -
airflow/example_dags/plugins/event_listener.py | 5 +-
airflow/jobs/scheduler_job_runner.py | 81 +-
.../versions/0047_3_0_0_add_dag_versioning.py | 158 +
...y => 0048_3_0_0_add_trigger_asset_reference.py} | 43 +-
airflow/models/__init__.py | 1 +
airflow/models/asset.py | 16 +-
airflow/models/backfill.py | 6 +-
airflow/models/dag.py | 26 +-
airflow/models/dag_version.py | 165 +
airflow/models/dagbag.py | 3 +-
airflow/models/dagcode.py | 117 +-
airflow/models/dagrun.py | 22 +-
airflow/models/serialized_dag.py | 141 +-
airflow/models/taskinstance.py | 14 +-
airflow/models/taskinstancehistory.py | 2 +
airflow/models/trigger.py | 3 +
airflow/serialization/pydantic/dag_run.py | 2 +-
airflow/serialization/schema.json | 1 +
airflow/ui/openapi-gen/queries/common.ts | 209 +
airflow/ui/openapi-gen/queries/prefetch.ts | 318 ++
airflow/ui/openapi-gen/queries/queries.ts | 344 ++
airflow/ui/openapi-gen/queries/suspense.ts | 344 ++
airflow/ui/openapi-gen/requests/schemas.gen.ts | 54 +
airflow/ui/openapi-gen/requests/services.gen.ts | 207 +
airflow/ui/openapi-gen/requests/types.gen.ts | 200 +
airflow/ui/package.json | 2 +-
airflow/ui/pnpm-lock.yaml | 22 +-
airflow/utils/dates.py | 6 +-
airflow/utils/db.py | 2 +-
airflow/www/views.py | 4 +-
contributing-docs/testing/unit_tests.rst | 6 +-
dev/README_RELEASE_PROVIDER_PACKAGES.md | 9 +-
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 4126 ++++++++++----------
docs/apache-airflow/migrations-ref.rst | 6 +-
hatch_build.py | 1 +
.../aws/auth_manager/cli/test_avp_commands.py | 6 +-
.../aws/auth_manager/test_aws_auth_manager.py | 31 +-
.../kubernetes/operators/test_spark_kubernetes.py | 8 -
providers/tests/common/sql/hooks/test_dbapi.py | 6 -
providers/tests/common/sql/hooks/test_sql.py | 5 -
providers/tests/common/sql/hooks/test_sqlparse.py | 6 -
providers/tests/common/sql/operators/test_sql.py | 4 +-
.../tests/common/sql/operators/test_sql_execute.py | 6 -
providers/tests/common/sql/test_utils.py | 9 -
.../api_endpoints/test_dag_run_endpoint.py | 1 +
.../tests/google/common/hooks/test_base_google.py | 2 +
providers/tests/openlineage/plugins/test_utils.py | 3 +-
.../ci/pre_commit/check_ti_vs_tis_attributes.py | 1 +
task_sdk/src/airflow/sdk/definitions/dag.py | 6 +
.../endpoints/test_dag_run_endpoint.py | 5 +-
.../api_connexion/endpoints/test_task_endpoint.py | 6 +-
.../core_api/routes/public/test_task_instances.py | 702 +++-
.../execution_api/routes/test_connection.py | 107 +
tests/cli/commands/test_task_command.py | 2 +-
tests/dag_processing/test_job_runner.py | 24 +-
tests/dag_processing/test_processor.py | 1 +
tests/jobs/test_scheduler_job.py | 257 +-
tests/models/test_dag.py | 24 +-
tests/models/test_dag_version.py | 113 +
tests/models/test_dagbag.py | 11 +-
tests/models/test_dagcode.py | 110 +-
tests/models/test_dagrun.py | 1 +
tests/models/test_serialized_dag.py | 111 +-
tests/models/test_taskinstance.py | 1 +
tests/operators/test_trigger_dagrun.py | 3 +-
tests/sensors/test_external_task_sensor.py | 3 +-
tests/utils/test_db_cleanup.py | 1 +
tests/www/views/test_views_tasks.py | 36 +-
tests_common/pytest_plugin.py | 78 +-
tests_common/test_utils/compat.py | 1 -
tests_common/test_utils/db.py | 5 +-
85 files changed, 6848 insertions(+), 2637 deletions(-)
create mode 100644 airflow/api_fastapi/execution_api/routes/connections.py
create mode 100644 airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
copy airflow/migrations/versions/{0022_2_10_0_add_dataset_alias.py =>
0048_3_0_0_add_trigger_asset_reference.py} (53%)
create mode 100644 airflow/models/dag_version.py
create mode 100644 tests/api_fastapi/execution_api/routes/test_connection.py
create mode 100644 tests/models/test_dag_version.py
