This is an automated email from the ASF dual-hosted git repository.
rahulvats pushed a change to branch v3-2-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 34da816343a Update default branches for 3-2
add 722fb25e4f1 Fix Celery worker crash on macOS due to unpicklable local
function (#62655)
add 2f051a82f44 Remove Connection dependency from shared secrets backend
(#61523)
add 6b79056562a add fix me to calendar tests (#62700)
add d785ca28fcd fix(breeze): use prek from breeze bin instead of PATH
(#62277)
add 6f9cc5f8fb4 Forbid accessing team secrets with environment variable as
global secret (#62588)
add ce005617edf Update dependencies for TS code in Fab Provider (#62679)
add f1cdbcb9712 Fix team-scoped auth check for POST variables,
connections, and pools in multi-team mode (#62511)
add 61bf9229c89 Pull the sphinx-airflow-theme wheel from
airflow.apache.org (#62710)
add 3161a80f5b0 Fix Toaster in Plugin in Edge UI (#55641)
add 5c79175e220 chore(deps): bump minimatch (#62712)
add 4d3230c4d2b Fix Trigger UI form rendering for null enum values (#62060)
add f42ffbcf167 Fix backward compatibility for workloads TaskInstance
import (#62714)
add 10b276afaa1 Fix prek arg (`--ref-from` -> `--from-ref`) in AGENTS.md
(#62675)
add b84fffbe664 Add workers.celery.keda section (#61820)
add cc4ac7784de feat: Add DagRun note to OL events (#62347)
add c6d8e167bd5 feat(keycloak): add method to retrieve teams from Keycloak
as resources (#62715)
add a15f3639395 Increase version airflowctl (#62255)
add 0791918c948 Delete `package-lock.json` in Simple auth manager (#62728)
add f83882e9460 Fix chart NOTES.txt showing deprecation warnings only
without secret key (#62722)
add fbf687cbb12 Chart: warn on deprecated per-component securityContext
values (#62729)
add 621792df82b Add `LLMBranchOperator` and `@task.llm_branch` to
`common.ai` provider (#62740)
add 26f85cf9dd2 Revert "Add resume_glue_job_on_retry to GlueJobOperator
(#59392)" (#62730)
add 382bdc3b864 Simplify fork remote detection in AGENTS.md (#62748)
add 823b41c9f28 Add clickable terminal links for issues and users in
`breeze issues unassign` (#62742)
add 60e4529dce8 Fix `common.ai` provider's dependencies (#62753)
add 182161b4e8f docs: edge3 db-manager is auto loaded by provider manager
(#62550)
add aa36f045d73 Move determine_kwargs and KeywordParameters to SDK
DecoratedOperator (#62746)
add 309d658204b Refactor task runner for spans (#62589)
add 7a301e69700 Fix XCom migration failing for NaN/Infinity float values
(#62686)
add 39d23c24afc Fix flaky calendar e2e test (#62718)
add 5d9b5df31f4 Fix: Restore task_instance_history sequence on downgrade
(#61976)
add f6b289ad032 Fix DagRan typo in DagRun.set_state docstring (#61788)
add b5eb4279c06 Refactor DataTable to handle internal scrolling and fix
overflow on narrow viewports (#62603)
add c7cbced1267 Move SkipMixin and BranchMixIn to Task SDK (#62749)
add 2feda387df3 Partition enhancements for peripheral features (#62463)
add f4ab33811f2 [main] Upgrade important CI environment (#62770)
add 483d84c6c95 Add iceberg support to AnalyticsOperator (#62754)
add 1199dc5305e Consolidate `SkipMixin` imports through `common-compat`
layer (#62776)
add 05ea74a9429 Prepare provider's documentation 2026-03-03 (#62752)
new 24e73b7be93 Update default branches for 3-2
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 (34da816343a)
\
N -- N -- N refs/heads/v3-2-test (24e73b7be93)
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.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.pre-commit-config.yaml | 2 +-
AGENTS.md | 26 +-
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/img/airflow_erd.svg | 5309 +++++------
airflow-core/docs/migrations-ref.rst | 4 +-
.../auth/managers/simple/ui/package-lock.json | 9501 --------------------
.../src/airflow/api_fastapi/core_api/security.py | 85 +-
airflow-core/src/airflow/cli/cli_config.py | 23 +-
.../src/airflow/cli/commands/dag_command.py | 74 +-
airflow-core/src/airflow/configuration.py | 9 +-
.../src/airflow/dag_processing/collection.py | 8 +-
.../example_dags/example_params_ui_tutorial.py | 5 +-
.../src/airflow/executors/workloads/__init__.py | 15 +-
.../src/airflow/jobs/scheduler_job_runner.py | 5 +-
...49_3_0_0_remove_pickled_data_from_xcom_table.py | 47 +-
.../0060_3_0_0_add_try_id_to_ti_and_tih.py | 25 +
...y => 0107_3_2_0_add_partition_fields_to_dag.py} | 35 +-
airflow-core/src/airflow/models/__init__.py | 7 +-
airflow-core/src/airflow/models/dag.py | 18 +-
airflow-core/src/airflow/models/dagrun.py | 5 +-
airflow-core/src/airflow/models/skipmixin.py | 22 -
airflow-core/src/airflow/models/team.py | 6 +
airflow-core/src/airflow/operators/__init__.py | 4 +-
airflow-core/src/airflow/secrets/base_secrets.py | 17 +-
.../src/airflow/secrets/environment_variables.py | 11 +
.../src/airflow/serialization/definitions/dag.py | 4 +
airflow-core/src/airflow/timetables/base.py | 31 +-
airflow-core/src/airflow/timetables/simple.py | 2 +
airflow-core/src/airflow/timetables/trigger.py | 59 +-
.../ui/src/components/DataTable/DataTable.tsx | 30 +-
.../components/FlexibleForm/FieldDropdown.test.tsx | 189 +
.../src/components/FlexibleForm/FieldDropdown.tsx | 49 +-
.../components/FlexibleForm/FieldMultiSelect.tsx | 10 +-
.../airflow/ui/src/pages/AssetsList/AssetsList.tsx | 26 +-
.../ui/src/pages/Connections/Connections.tsx | 28 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 2 +-
.../airflow/ui/src/pages/Variables/Variables.tsx | 26 +-
.../src/airflow/ui/src/queries/useDagParams.ts | 2 +-
.../ui/tests/e2e/specs/dag-calendar-tab.spec.ts | 16 +-
airflow-core/src/airflow/utils/db.py | 2 +-
airflow-core/src/airflow/utils/operator_helpers.py | 89 +-
airflow-core/tests/unit/always/test_connection.py | 5 +-
airflow-core/tests/unit/always/test_secrets.py | 21 +
.../tests/unit/always/test_secrets_backends.py | 2 +
.../unit/api_fastapi/core_api/test_security.py | 272 +-
.../tests/unit/cli/commands/test_dag_command.py | 50 +-
.../unit/executors/test_workloads.py} | 11 +-
airflow-core/tests/unit/models/test_dag.py | 24 +-
airflow-core/tests/unit/models/test_team.py | 8 +
.../unit/timetables/test_trigger_timetable.py | 23 +-
airflow-ctl/src/airflowctl/__init__.py | 2 +-
chart/docs/keda.rst | 4 +-
chart/newsfragments/61820.significant.rst | 1 +
chart/templates/NOTES.txt | 99 +-
chart/templates/_helpers.yaml | 8 +-
.../pgbouncer/pgbouncer-networkpolicy.yaml | 10 +-
.../secrets/metadata-connection-secret.yaml | 10 +-
.../triggerer/triggerer-kedaautoscaler.yaml | 2 +-
chart/values.schema.json | 116 +-
chart/values.yaml | 48 +
.../src/airflow_breeze/commands/issues_commands.py | 27 +-
dev/breeze/src/airflow_breeze/global_constants.py | 4 +-
dev/breeze/src/airflow_breeze/utils/run_utils.py | 12 +-
dev/breeze/tests/test_selective_checks.py | 2 +-
dev/breeze/uv.lock | 12 +-
devel-common/pyproject.toml | 2 +-
docs/spelling_wordlist.txt | 1 +
.../tests/helm_tests/airflow_core/test_worker.py | 117 +-
.../helm_tests/airflow_core/test_worker_sets.py | 252 +-
helm-tests/tests/helm_tests/other/test_keda.py | 234 +-
.../tests/helm_tests/other/test_pgbouncer.py | 166 +-
providers/.last_release_date.txt | 2 +-
providers/amazon/docs/changelog.rst | 7 +-
.../airflow/providers/amazon/aws/operators/glue.py | 33 +-
.../tests/unit/amazon/aws/operators/test_glue.py | 101 -
.../unit/amazon/aws/transfers/test_s3_to_sql.py | 30 +-
.../providers/apache/iceberg/hooks/iceberg.py | 5 +-
.../unit/apache/iceberg/hooks/test_iceberg.py | 18 +
.../livy/tests/unit/apache/livy/hooks/test_livy.py | 3 +-
providers/celery/docs/changelog.rst | 4 +
.../airflow/providers/celery/cli/celery_command.py | 20 +-
.../tests/unit/celery/cli/test_celery_command.py | 13 +-
providers/cncf/kubernetes/pyproject.toml | 2 +-
.../cncf/kubernetes/decorators/kubernetes_cmd.py | 2 +-
providers/common/ai/docs/index.rst | 15 +-
providers/common/ai/docs/operators/llm_branch.rst | 97 +
providers/common/ai/provider.yaml | 4 +
providers/common/ai/pyproject.toml | 6 +-
.../airflow/providers/common/ai/decorators/llm.py | 2 +-
.../common/ai/decorators/{llm.py => llm_branch.py} | 60 +-
.../providers/common/ai/decorators/llm_sql.py | 2 +-
.../common/ai/example_dags/example_llm_branch.py | 152 +
.../providers/common/ai/get_provider_info.py | 6 +
.../providers/common/ai/operators/llm_branch.py | 94 +
.../decorators/{test_llm.py => test_llm_branch.py} | 57 +-
.../unit/common/ai/operators/test_llm_branch.py | 162 +
.../src/airflow/providers/common/compat/sdk.py | 16 +
.../providers/common/compat/standard/operators.py | 2 +
.../providers/common/compat/standard/utils.py | 17 +
providers/common/sql/docs/index.rst | 15 +-
providers/common/sql/docs/operators.rst | 10 +
providers/common/sql/pyproject.toml | 17 +-
.../sql/src/airflow/providers/common/sql/config.py | 43 +-
.../providers/common/sql/datafusion/base.py | 13 +-
.../providers/common/sql/datafusion/engine.py | 19 +-
.../providers/common/sql/datafusion/exceptions.py | 4 +
.../common/sql/datafusion/format_handlers.py | 123 +-
.../providers/common/sql/decorators/analytics.py | 2 +-
.../airflow/providers/common/sql/decorators/sql.py | 2 +-
.../common/sql/example_dags/example_analytics.py | 34 +-
.../airflow/providers/common/sql/operators/sql.py | 4 +-
.../common/sql/datafusion/test_format_handlers.py | 173 +-
.../sql/tests/unit/common/sql/test_config.py | 23 +-
providers/edge3/docs/changelog.rst | 13 +
providers/edge3/docs/deployment.rst | 14 +-
.../plugins/www/src/components/ui/createToaster.ts | 24 -
.../edge3/plugins/www/src/components/ui/index.ts | 2 +-
.../plugins/www/src/components/ui/toaster.tsx | 30 +-
.../edge3/plugins/www/src/layouts/EdgeLayout.tsx | 6 +-
providers/elasticsearch/docs/changelog.rst | 3 +
.../fab/src/airflow/providers/fab/www/package.json | 6 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 39 +-
providers/informatica/README.rst | 6 +-
providers/informatica/docs/changelog.rst | 2 +-
providers/informatica/docs/index.rst | 6 +-
providers/informatica/provider.yaml | 2 +-
providers/informatica/pyproject.toml | 6 +-
.../src/airflow/providers/informatica/__init__.py | 2 +-
.../keycloak/auth_manager/keycloak_auth_manager.py | 18 +
.../auth_manager/test_keycloak_auth_manager.py | 27 +
.../airflow/providers/openlineage/utils/utils.py | 8 +-
.../providers/openlineage/version_compat.py | 3 +-
.../tests/unit/openlineage/utils/test_utils.py | 22 +-
providers/standard/pyproject.toml | 2 +-
.../airflow/providers/standard/decorators/bash.py | 2 +-
.../airflow/providers/standard/operators/branch.py | 8 +-
.../providers/standard/operators/datetime.py | 3 +-
.../airflow/providers/standard/operators/hitl.py | 4 +-
.../providers/standard/operators/latest_only.py | 2 +-
.../airflow/providers/standard/operators/python.py | 18 +-
.../providers/standard/operators/weekday.py | 3 +-
.../tests/unit/standard/operators/test_weekday.py | 2 +-
.../tests/unit/standard/utils/test_skipmixin.py | 4 +-
.../src/airflow_shared/secrets_backend/base.py | 54 +-
.../tests/secrets_backend/test_base.py | 40 +
task-sdk/docs/api.rst | 6 +
task-sdk/src/airflow/sdk/__init__.py | 8 +
task-sdk/src/airflow/sdk/__init__.pyi | 8 +
.../src/airflow/sdk/bases}/branch.py | 11 +-
task-sdk/src/airflow/sdk/bases/decorator.py | 64 +
task-sdk/src/airflow/sdk/bases/secrets_backend.py | 16 +-
.../src/airflow/sdk/bases}/skipmixin.py | 45 +-
task-sdk/src/airflow/sdk/configuration.py | 9 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 2 +-
.../airflow/sdk/definitions/timetables/trigger.py | 6 +-
.../src/airflow/sdk/execution_time/task_runner.py | 9 +-
task-sdk/tests/task_sdk/bases/test_branch.py | 121 +
task-sdk/tests/task_sdk/bases/test_skipmixin.py | 202 +
task-sdk/tests/task_sdk/docs/test_public_api.py | 1 +
.../task_sdk/execution_time/test_task_runner.py | 17 +-
160 files changed, 6379 insertions(+), 13316 deletions(-)
delete mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/package-lock.json
copy
airflow-core/src/airflow/migrations/versions/{0099_3_2_0_add_exceeds_max_runs_flag_to_dag_model.py
=> 0107_3_2_0_add_partition_fields_to_dag.py} (53%)
delete mode 100644 airflow-core/src/airflow/models/skipmixin.py
create mode 100644
airflow-core/src/airflow/ui/src/components/FlexibleForm/FieldDropdown.test.tsx
copy airflow-core/{src/airflow/api/client/__init__.py =>
tests/unit/executors/test_workloads.py} (72%)
create mode 100644 chart/newsfragments/61820.significant.rst
create mode 100644 providers/common/ai/docs/operators/llm_branch.rst
copy providers/common/ai/src/airflow/providers/common/ai/decorators/{llm.py =>
llm_branch.py} (64%)
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_llm_branch.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/operators/llm_branch.py
copy providers/common/ai/tests/unit/common/ai/decorators/{test_llm.py =>
test_llm_branch.py} (58%)
create mode 100644
providers/common/ai/tests/unit/common/ai/operators/test_llm_branch.py
delete mode 100644
providers/edge3/src/airflow/providers/edge3/plugins/www/src/components/ui/createToaster.ts
copy airflow-core/src/airflow/ui/src/components/ui/Toaster/Toaster.tsx =>
providers/edge3/src/airflow/providers/edge3/plugins/www/src/components/ui/toaster.tsx
(54%)
copy {providers/standard/src/airflow/providers/standard/operators =>
task-sdk/src/airflow/sdk/bases}/branch.py (91%)
copy {providers/standard/src/airflow/providers/standard/utils =>
task-sdk/src/airflow/sdk/bases}/skipmixin.py (78%)
create mode 100644 task-sdk/tests/task_sdk/bases/test_branch.py
create mode 100644 task-sdk/tests/task_sdk/bases/test_skipmixin.py
