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 5fdf2ec0ee6 Merge branch 'main' of https://github.com/apache/airflow
into handle-stuck-in-queue
add 2a77f4d4c46 Remove note about MySQL 5 (#43701)
add dd9b7356ad1 AIP-84 Use status constants (#43702)
add 71b8d9ff50a Update Breeze UI Files to match `pnpm` lock file (#43699)
add 43f3c31d28d Add AWS Redshift Serverless support to PostgresHook
(#43669)
add 995cd8fba8d (bugfix): `EcsRunTaskOperator` decouple
`volume_configurations` from `capacity_provider_strategy` (#43047)
add cd75707d7d3 AIP-84 Migrate patch a connection to FastAPI API (#43102)
add 464f7c45603 Move responsibility to run a command from WinRMOperator to
WinRMHook (#43646)
add ef81cdfa246 Added contributors documentation regarding configuration
of source root directories in PyCharm (#43727)
add 3c04a8b1479 Chart: Default airflow version to 2.10.3 (#43698)
add 469dd75ebe9 bugfix description should be optional for openlineage
integration with `AthenaOperator` (#43576)
add 80727d42ab2 Temporarily limit openlineage to <1.24.0 (#43732)
add 26eaeedb4dc Beautify queues output on overviewer page (#43734)
add b757bd8df82 Temporarily revert dag versioning changes (#43730)
add b89f43ebe1a Add dag source code to dag details page (#43633)
add f05716bb0b9 Add GZipMiddleware to compress response content. (#43707)
add 7f4b7fdea28 Add data-testid attributes to UI elements for unit test
and automation tests (#43736)
add 71f9d2b7e55 Airflow 2.10.3 has been released (#43697)
add c7c65474810 OpenLineage: accept whole config when instantiating
OpenLineageClient. (#43740)
add d41c859cf33 Remove schedule downstream tasks after execution (aka
"mini scheduler") (#43741)
add 2d8f7143180 Bump happy-dom from 15.0.0 to 15.10.1 in /airflow/ui
(#43759)
add bab8f40731c AIP-72: Add "TI heartbeat" endpoint for Execution API
(#43722)
add 66d3df23914 Remove connections file in Execution API (#43761)
add 9a9497bde49 Check if awslogs_stream_prefix already ends with
container_name (#43724)
add a0a3b8a50fb Enable workload identity authentication for the Databricks
provider (#41639)
add 3885c9eb6f5 Update helm chart docs for private registry params (#43721)
add 96611dbc794 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:
.github/ISSUE_TEMPLATE/airflow_bug_report.yml | 2 +-
Dockerfile | 2 +-
README.md | 16 +-
RELEASE_NOTES.rst | 63 +
airflow/api/common/trigger_dag.py | 5 +-
.../api_connexion/endpoints/connection_endpoint.py | 1 +
.../api_connexion/endpoints/dag_run_endpoint.py | 5 +-
airflow/api_fastapi/core_api/app.py | 6 +
.../api_fastapi/core_api/openapi/v1-generated.yaml | 89 +-
.../core_api/routes/public/connections.py | 47 +-
.../core_api/routes/public/dag_stats.py | 11 +-
airflow/api_fastapi/core_api/routes/public/dags.py | 20 +-
.../core_api/routes/public/variables.py | 8 +-
.../api_fastapi/core_api/routes/ui/dashboard.py | 4 +-
.../api_fastapi/core_api/serializers/variables.py | 17 +-
.../execution_api/routes/task_instance.py | 68 +-
airflow/api_fastapi/execution_api/schemas.py | 7 +
airflow/config_templates/config.yml | 9 -
airflow/dag_processing/manager.py | 15 +
airflow/example_dags/plugins/event_listener.py | 5 +-
airflow/jobs/local_task_job_runner.py | 6 +-
airflow/jobs/scheduler_job_runner.py | 22 +-
.../versions/0047_3_0_0_add_dag_versioning.py | 158 -
airflow/models/__init__.py | 1 -
airflow/models/backfill.py | 6 +-
airflow/models/dag.py | 26 +-
airflow/models/dag_version.py | 167 -
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 | 108 +-
airflow/models/taskinstancehistory.py | 2 -
airflow/reproducible_build.yaml | 4 +-
airflow/serialization/pydantic/dag_run.py | 2 +-
airflow/serialization/pydantic/taskinstance.py | 10 -
airflow/serialization/schema.json | 1 -
airflow/ui/openapi-gen/queries/common.ts | 3 +
airflow/ui/openapi-gen/queries/queries.ts | 47 +
airflow/ui/openapi-gen/requests/schemas.gen.ts | 20 +-
airflow/ui/openapi-gen/requests/services.gen.ts | 38 +-
airflow/ui/openapi-gen/requests/types.gen.ts | 45 +-
airflow/ui/package.json | 4 +-
airflow/ui/pnpm-lock.yaml | 203 +-
airflow/ui/src/components/DataTable/CardList.tsx | 2 +-
airflow/ui/src/components/DataTable/TableList.tsx | 7 +-
airflow/ui/src/components/SearchBar.tsx | 1 +
airflow/ui/src/pages/DagsList/Dag/Code/Code.tsx | 145 +
.../Nav => pages/DagsList/Dag/Code}/index.ts | 2 +-
airflow/ui/src/pages/DagsList/Dag/Dag.tsx | 85 +-
airflow/ui/src/router.tsx | 13 +-
airflow/utils/db.py | 2 +-
airflow/www/views.py | 4 +-
chart/Chart.yaml | 20 +-
chart/newsfragments/42406.significant.rst | 3 -
chart/newsfragments/43698.significant.rst | 3 +
chart/values.schema.json | 12 +-
chart/values.yaml | 4 +-
.../contributors_quick_start_pycharm.rst | 18 +
.../pycharm_adding_source_root_directories.png | Bin 0 -> 187571 bytes
.../images/pycharm_invalidate_caches.png | Bin 0 -> 82827 bytes
.../src/airflow_breeze/utils/selective_checks.py | 8 +-
.../connections/databricks.rst | 1 +
.../administration-and-deployment/scheduler.rst | 5 -
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 3942 ++++++++++----------
.../installation/supported-versions.rst | 2 +-
docs/apache-airflow/migrations-ref.rst | 4 +-
docs/spelling_wordlist.txt | 2 +
generated/PYPI_README.md | 14 +-
generated/provider_dependencies.json | 4 +-
hatch_build.py | 1 -
newsfragments/43102.significant.rst | 18 +
.../providers/amazon/aws/operators/athena.py | 4 +-
.../airflow/providers/amazon/aws/operators/ecs.py | 12 +-
.../providers/databricks/hooks/databricks_base.py | 98 +
providers/src/airflow/providers/edge/CHANGELOG.rst | 8 +
providers/src/airflow/providers/edge/__init__.py | 2 +-
.../src/airflow/providers/edge/cli/edge_command.py | 2 -
.../edge/plugins/templates/edge_worker_hosts.html | 12 +-
providers/src/airflow/providers/edge/provider.yaml | 2 +-
.../providers/microsoft/winrm/hooks/winrm.py | 72 +
.../providers/microsoft/winrm/operators/winrm.py | 73 +-
.../providers/openlineage/plugins/adapter.py | 8 +-
.../airflow/providers/openlineage/provider.yaml | 4 +-
.../airflow/providers/postgres/hooks/postgres.py | 36 +-
.../amazon/aws/operators/athena_metadata.json | 3 +-
.../tests/amazon/aws/operators/test_athena.py | 2 +-
providers/tests/amazon/aws/operators/test_ecs.py | 70 +-
.../cncf/kubernetes/decorators/test_kubernetes.py | 25 -
.../test_databricks_azure_workload_identity.py | 90 +
...est_databricks_azure_workload_identity_async.py | 89 +
.../api_endpoints/test_dag_run_endpoint.py | 1 -
.../tests/microsoft/winrm/hooks/test_winrm.py | 84 +-
.../tests/openlineage/plugins/test_adapter.py | 11 -
providers/tests/postgres/hooks/test_postgres.py | 74 +
.../ci/pre_commit/check_ti_vs_tis_attributes.py | 1 -
scripts/ci/pre_commit/supported_versions.py | 2 +-
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_connections.py | 275 ++
.../execution_api/routes/test_task_instance.py | 169 +
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_local_task_job.py | 158 -
tests/jobs/test_scheduler_job.py | 219 +-
tests/models/test_dag.py | 24 +-
tests/models/test_dag_version.py | 113 -
tests/models/test_dagbag.py | 14 +-
tests/models/test_dagcode.py | 110 +-
tests/models/test_dagrun.py | 1 -
tests/models/test_serialized_dag.py | 111 +-
tests/models/test_taskinstance.py | 268 +-
tests/operators/test_trigger_dagrun.py | 13 +-
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 | 66 +-
tests_common/test_utils/db.py | 1 -
121 files changed, 4408 insertions(+), 3883 deletions(-)
delete mode 100644 airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
delete mode 100644 airflow/models/dag_version.py
create mode 100644 airflow/ui/src/pages/DagsList/Dag/Code/Code.tsx
copy airflow/ui/src/{layouts/Nav => pages/DagsList/Dag/Code}/index.ts (96%)
delete mode 100644 chart/newsfragments/42406.significant.rst
create mode 100644 chart/newsfragments/43698.significant.rst
create mode 100644
contributing-docs/quick-start-ide/images/pycharm_adding_source_root_directories.png
create mode 100644
contributing-docs/quick-start-ide/images/pycharm_invalidate_caches.png
create mode 100644 newsfragments/43102.significant.rst
create mode 100644
providers/tests/databricks/hooks/test_databricks_azure_workload_identity.py
create mode 100644
providers/tests/databricks/hooks/test_databricks_azure_workload_identity_async.py
delete mode 100644 tests/models/test_dag_version.py