This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch reintro-venv-task-supervisor
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 3498a412707 fixup! Support for "reconnecting" Supervisor Comms from
task process when `dag.test()` are used
discard e8c3e8393eb Support for "reconnecting" Supervisor Comms from task
process when `dag.test()` are used
add 801f0316a8a fix mypy errors in scheduler_job_runner.py (#58167)
add 8bfe744fe13 CI: Upgrade important CI environment (#58164)
add 3afad4d908d Patch pools should have an optional description (#58066)
add 805a4750411 Update UI to allow creation of DagRuns with partition key
(#58004)
add 2ccd348294f Bump boto3 from 1.40.68 to 1.40.69 in /dev/breeze (#58160)
add b77f7a74b61 Remove unnecessary list (#58141)
add 152e9a830eb RFC: Close italian gap airflow 3.1 (#58120)
add bbcb63b4156 Indent todo comment for IDE highlighting compatibility
(#58174)
add 8b358bd6c6e Fix CI upgrade script to not delete branch from origin
remote (#58163)
add bf38405bdd2 Upgrade email notifications to use SmtpNotifier (#57354)
add 48937a5348e Group upgrades of python dependencies (#58162)
add e6448226ed5 Fix Enum-str interpolation in callback metrics in Python
3.11+ (#58168)
add da0940431b3 fix(migration): disable sqlite fkeys (#58130)
add f9b0ca76018 Fix location of comment in dags_needing_dagruns (#58173)
add e615354e34f Create additional users in breeze for testing (#58126)
add 9ba09f3e072 Add HTTP URL authentication support to GitHook (#58194)
add c25b89b0c93 Add push_logs configuration option to Edge executor
(#58125)
add ca9fb54fe75 Update release instructions for Airflow Ctl (#58206)
add 4688c68f126 Rename task sdk integration tests folder hierarchy
correctly (#58193)
add 80c2ccc0b43 Fix the `__init__.py` for tests (#58211)
add 4bde26ffb54 Make sure regenerating provider dependencies happens only
once (#58198)
add 5dc5ba27895 Support for "reconnecting" Supervisor Comms from task
process when `dag.test()` are used
add 0006975e00b fixup! Support for "reconnecting" Supervisor Comms from
task process when `dag.test()` are used
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 (3498a412707)
\
N -- N -- N refs/heads/reintro-venv-task-supervisor (0006975e00b)
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:
.dockerignore | 2 +-
.github/CODEOWNERS | 2 +-
.github/actions/breeze/action.yml | 2 +-
.github/actions/install-prek/action.yml | 2 +-
.github/dependabot.yml | 16 ++
.github/workflows/basic-tests.yml | 2 +-
.github/workflows/release_dockerhub_image.yml | 2 +-
Dockerfile | 4 +-
Dockerfile.ci | 4 +-
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/img/airflow_erd.svg | 142 ++++++++---------
.../api_fastapi/core_api/datamodels/assets.py | 2 +
.../api_fastapi/core_api/datamodels/dag_run.py | 3 +
.../api_fastapi/core_api/datamodels/pools.py | 2 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 22 ++-
.../api_fastapi/core_api/routes/public/assets.py | 1 +
.../api_fastapi/core_api/routes/public/dag_run.py | 1 +
.../execution_api/datamodels/asset_event.py | 1 +
.../execution_api/datamodels/taskinstance.py | 1 +
.../execution_api/routes/asset_events.py | 1 +
.../api_fastapi/execution_api/versions/__init__.py | 2 +
.../versions/{v2025_08_10.py => v2025_11_07.py} | 36 ++---
.../src/airflow/dag_processing/processor.py | 6 +-
.../src/airflow/jobs/scheduler_job_runner.py | 51 +++---
.../0082_3_1_0_make_bundle_name_not_nullable.py | 15 +-
airflow-core/src/airflow/models/callback.py | 5 +-
airflow-core/src/airflow/models/dag.py | 8 +-
airflow-core/src/airflow/models/dagrun.py | 1 +
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 48 +++++-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 6 +-
.../airflow/ui/public/i18n/locales/en/common.json | 1 +
.../airflow/ui/public/i18n/locales/it/common.json | 15 +-
.../ui/public/i18n/locales/it/components.json | 8 +
.../src/airflow/ui/public/i18n/locales/it/dag.json | 2 +
.../airflow/ui/public/i18n/locales/it/hitl.json | 5 +
.../src/components/TriggerDag/TriggerDAGForm.tsx | 21 +++
.../ui/src/pages/Asset/CreateAssetEventModal.tsx | 24 ++-
.../src/airflow/ui/src/pages/Pools/PoolForm.tsx | 14 +-
.../src/airflow/ui/src/pages/Run/Header.tsx | 8 +
.../src/airflow/ui/src/queries/useEditPool.ts | 5 +-
.../src/airflow/ui/src/queries/useTrigger.ts | 1 +
.../core_api/routes/public/test_assets.py | 7 +
.../core_api/routes/public/test_connections.py | 4 +-
.../core_api/routes/public/test_dag_run.py | 5 +
.../core_api/routes/public/test_pools.py | 6 -
.../versions/head/test_asset_events.py | 17 ++
.../versions/head/test_task_instances.py | 1 +
.../versions/v2025_09_23/test_asset_events.py | 166 ++++++++++++++++++++
.../tests/unit/callbacks/test_callback_requests.py | 6 +
.../tests/unit/cli/commands/test_asset_command.py | 2 +
.../tests/unit/dag_processing/test_processor.py | 74 ++++++---
airflow-core/tests/unit/models/test_callback.py | 6 +-
airflow-ctl/pyproject.toml | 14 ++
.../src/airflowctl/api/datamodels/generated.py | 4 +
.../testing/task_sdk_integration_tests.rst | 22 +--
dev/README_RELEASE_AIRFLOWCTL.md | 90 ++++++-----
dev/breeze/doc/03_developer_tasks.rst | 38 ++++-
dev/breeze/doc/05_test_commands.rst | 2 +-
dev/breeze/doc/ci/02_images.md | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 40 +++--
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
dev/breeze/pyproject.toml | 2 +-
.../src/airflow_breeze/commands/ci_commands.py | 5 -
.../airflow_breeze/commands/developer_commands.py | 9 ++
.../commands/developer_commands_config.py | 4 +-
.../commands/release_management_commands.py | 2 +-
.../files/simple_auth_manager_passwords.json | 2 +-
dev/breeze/src/airflow_breeze/global_constants.py | 37 ++++-
.../src/airflow_breeze/params/shell_params.py | 6 +-
.../src/airflow_breeze/utils/md5_build_check.py | 6 +-
dev/breeze/src/airflow_breeze/utils/run_tests.py | 2 +-
dev/breeze/uv.lock | 172 +++++++++++----------
devel-common/pyproject.toml | 2 +-
.../tests_common/_internals/forbidden_warnings.py | 16 +-
devel-common/src/tests_common/pytest_plugin.py | 5 +-
.../airflow/providers/amazon/aws/utils/mixins.py | 2 +-
.../apache/impala/tests/system}/__init__.py | 0
.../apache/tinkerpop/tests/integration/__init__.py | 1 +
.../apache/tinkerpop/tests/system/__init__.py | 1 +
providers/edge3/provider.yaml | 9 ++
.../src/airflow/providers/edge3/cli/worker.py | 6 +-
.../airflow/providers/edge3/get_provider_info.py | 7 +
providers/exasol/tests/system/__init__.py | 1 +
.../git/src/airflow/providers/git/hooks/git.py | 5 +
providers/git/tests/unit/__init__.py | 1 +
providers/git/tests/unit/git/hooks/test_git.py | 30 ++++
pyproject.toml | 12 +-
.../check_providers_subpackages_all_have_init.py | 2 +-
.../docker/install_airflow_when_building_images.sh | 2 +-
scripts/in_container/check_environment.sh | 12 +-
scripts/tools/setup_breeze | 2 +-
setup_idea.py | 2 +-
.../dags/test_asset_dag.py | 0
.../dags/test_dag.py | 0
.../docker/docker-compose.yaml | 0
.../pyproject.toml | 4 +-
.../tests/task_sdk_tests/__init__.py | 0
.../tests/task_sdk_tests/conftest.py | 0
.../tests/task_sdk_tests/constants.py | 0
.../tests/task_sdk_tests/jwt_plugin.py | 0
.../task_sdk_tests/test_asset_event_operations.py | 0
.../tests/task_sdk_tests/test_asset_operations.py | 0
.../task_sdk_tests/test_connection_operations.py | 0
.../task_sdk_tests/test_dag_run_operations.py | 0
.../test_task_instance_operations.py | 0
.../tests/task_sdk_tests/test_task_sdk_health.py | 0
.../task_sdk_tests/test_variable_operations.py | 0
.../tests/task_sdk_tests/test_xcom_operations.py | 0
.../src/airflow/sdk/api/datamodels/_generated.py | 4 +-
.../src/airflow/sdk/execution_time/task_runner.py | 145 ++++++++---------
.../task_sdk/execution_time/test_supervisor.py | 1 +
.../task_sdk/execution_time/test_task_runner.py | 168 ++++++++++++++++++++
112 files changed, 1214 insertions(+), 477 deletions(-)
copy
airflow-core/src/airflow/api_fastapi/execution_api/versions/{v2025_08_10.py =>
v2025_11_07.py} (53%)
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2025_09_23/test_asset_events.py
copy {airflow-core/tests/integration =>
providers/apache/impala/tests/system}/__init__.py (100%)
rename {task-sdk-tests => task-sdk-integration-tests}/dags/test_asset_dag.py
(100%)
rename {task-sdk-tests => task-sdk-integration-tests}/dags/test_dag.py (100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/docker/docker-compose.yaml (100%)
rename {task-sdk-tests => task-sdk-integration-tests}/pyproject.toml (93%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/__init__.py (100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/conftest.py (100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/constants.py (100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/jwt_plugin.py (100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/test_asset_event_operations.py
(100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/test_asset_operations.py (100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/test_connection_operations.py
(100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/test_dag_run_operations.py
(100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/test_task_instance_operations.py
(100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/test_task_sdk_health.py (100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/test_variable_operations.py
(100%)
rename {task-sdk-tests =>
task-sdk-integration-tests}/tests/task_sdk_tests/test_xcom_operations.py (100%)
