This is an automated email from the ASF dual-hosted git repository.
msumit pushed a change to branch sumit/update_api
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 3be920e8b12 Add licence in test file
add bcb42e29c2d Activate assets before adding trigger references (#50638)
add a68afb40498 fix annotation for user (#50807)
add e4473bb1b94 Fix Celery executor subprocess to stream stdout/stderr
using subprocess.run (#50682)
add 0dbfd0c7f93 Fix KubernetesPodOperator AutomountServiceAccountToken
from Pod Template (#50800)
add 967da374792 Pass workload to KE using command args instead of init
container (#50448)
add 751c7bf7159 Fix the docstring for
airflow.sdk.execution_time.superviseor.supervise (#50805)
add e6282e0e654 make dag_run nullable in Details page (#50719)
add dffea5917de Prepare release for cncf.kubernetes rc2 May 2025 (#50813)
add 34254b2c837 Remove doc warning for macros defined via plugins (#50810)
add 0d6e4a420ea Remove redundant sentence in Airflow release docs (#50820)
add dadee4baae0 Add `AGENT.md` for using OpenAI Codex (#50824)
add 649309e4e5f Move webserver config to fab provider (#50774)
add 0b0ff5d1180 fix: resolve 404 log error for non-latest task tries in
multi-host worker environments (#50175)
add ac84c4e2cc8 Bump the fab-ui-package-updates group across 1 directory
with 2 updates (#50783)
add dfec1a79bee AWS ECS Executor. Assign public ip defaults false (#50713)
add 511eaacf136 Generated yaml files should not have licence added (#50830)
add 6ee5949cdd9 Update docs with Airflow 2.11.0 info (#50832)
add 8b5f0cf6666 Remove unecessary breaking flag in config command (#50781)
add 83d659bec7c CI: Proper check for skipping writing doc to stable
version (#50838)
add ccca0720b64 Update release manager guide for providers (#50822)
add 0a3b58abf37 Stabilize FAB asset compilation (#50829)
add 0e46cf733fe Add missing pipe in exclude configuration (#50849)
add f9afd0c4ea8 Typo in the previous fix - needs also to remove \ (#50851)
add 687decf2988 Update docs for Python client (#50850)
add b566a0b57f4 Bump webpack from 5.99.8 to 5.99.9 in
/providers/fab/src/airflow/providers/fab/www in the fab-ui-package-updates
group across 1 directory (#50847)
add 8c0d27374d5 Fix dropdowns in accordion and error text colors (#50845)
add 06278ce0d4e Update useTableURLState hook for sticky table sort (#50720)
add e1f4290de84 Fix the version for generated client (#50859)
add 3a9858e7360 Port `task.test` to Task SDK (#50827)
add 8bf6c9899f0 Fix Example tutorial_objectstorage DAG (#50828)
add 3e6fc3837b2 Fix backward compatibility for timeout in defer() with
Airflow 2.11 (#50869)
add 4af10c9c386 Bumping pinecone sdk to 7.0.0 to improve podspec handling
(#50868)
add 3e4104b06f7 API handle slashes in variable keys (#50841)
add c5dfb1145c0 Use explicit directives instead of implicit syntax (#50870)
add 62678f90b91 EmptyOperator raises InvalidURL for non-existing logs
(#50325)
add 13c6020278d Fix reading number of dags from direct system providers
path (#50843)
add a17d14edcf5 misc updates to provider release guide (#50881)
add 611270abdf3 Do not run FAB pre-commits in release branches (#50875)
add e45bdaca498 Bump min version of neo4j sdk to 5.20 (#50882)
add 0e0d4c5b869 Remove deprecated for December 2024 and April 2025 in
providers/google. (#50021)
add a1b2c0c3982 Update providers metadata 2025-05-21 (#50879)
add 854b80ad4ea Add fetch depth to compare commit history (#50883)
add ba67365516c fix: Duplicate region in Snowflake URI no longer breaks
OpenLineage (#50831)
add 334d52e2eb7 exclude venv breeze from pycharm discovery (#50888)
add 97913b05283 Further prune release notes (#50860)
add fcd815d16d7 Add fetch tags to true for publish docs (#50887)
add 6a678060afd Deserialize should work while retrieving variables with
secrets backend (#50880)
add 4c39e468597 Move secret_key config to api section (#50839)
add c674e124ce0 We actually need to fetch more than 2 commits to fetch
logs (#50893)
add e52e8ac8bfe Bugfix: Logical date isn't populated in Context vars:
(#50898)
add 0486e6e5a34 Update config endpoint to use the get interface (#50902)
add 4099a902fcc Feature/implement i18n for Dashboard and SideBar (#50626)
add 4efa9b5660c Bump the core-ui-package-updates group across 1 directory
with 11 updates (#50789)
add 7d69f2e782c Move enable_swagger_ui config to api (#50896)
add 396810d36f2 Make test_dagbag test work locally, not only in Breeze
(#50916)
add 92df334614b Fix docstring for _creator_note function in dagrun and
taskinstance (#50920)
add c6d9afa9fe8 Add Airflow 2.10.5 to Back-Compat tests (#50865)
add 4f94f2257ae Mask variable values in task logs only if the variable key
is sensitive (#50775)
add f3ced9a33d7 Fixing failing upgrade checks on main (#50936)
add 1f192bdd92e Add Deadline relationship to DagRun and update Deadline
model (#50925)
add 8e97af069a8 ci(script): fix check_deferrable_default.py target path
(#50934)
add baef759e544 fix(providers/google): update the default value of
PubSubPullOperator.deferrable to conf.getboolean("operators",
"default_deferrable", fallback=False) (#50935)
add b14f16c5ccc Always use shared cache, no matter if we are using uv or
not (#50923)
add d04f00ec166 Add creating docs in stage for providers release (#50942)
add 82c1c9db78f Update Airflow 3 migration guide with step about custom
operators (#50871)
add e033afab423 Make is_stdout work when sys.stdout does not have a fd
(#50328)
add 5458e7e7be8 fix(task_instances): handle upstream_mapped_index when
xcom access is needed (#50641)
add f7b8ccd311d Move macros to task SDK execution_time module (#50940)
add 5796536e0f5 Do not use outdated schedule_interval in tutorial dags
(#50947)
add 5fed2ebf544 Move AWS auth dependencies to python3-saml extra (#50449)
add 2e55c8d49bc Bump openlineage-airflow from 1.32.1 to 1.33.0 (#50790)
add 9faf9d93744 Move or delete remaining webserver config options (#50899)
add fb8c8770b3f Isolate celery tests to separate container (#50952)
add ad7f8c7f869 Add custom headers and cookies support in WebHDFSHook
(#50955)
add 40e997a222b Fix aws_conn_id defaulting after dag.test was updated to
use TaskSDK. (#50515)
add dbe707c2a64 Fix wrong import for PythonOperator in tutorial dag
(#50962)
add 59638206e11 Migrate Dashboard plaintext to i18n files (#50930)
add 5d3f1919488 docs(CODEOWNERS): Add Lee-W as Mandarian translation code
owner (#50951)
add ffa16228db1 Preemptively add proper Apache license for wordcount.go
(#50968)
add f8c820040ae Always show backfill button but enable it only on dags
with schedule. (#50969)
add 3f44d03085b Make `v2-11-stable` a protected branch (#50966)
add d9eec6ac447 Fix a bug where Kube config
"worker_pod_pending_fatal_container_state_reasons" is parsed wrongly (#50931)
add 2df35def708 Fix release process for Python Client (#50972)
add e471a3a6104 Increase timeouts for unit tests (#50973)
add f1ca1d1b90d Port ``ti.run`` to Task SDK execution path (#50141)
add d58a0f22153 feat: add create_collection function to MongoHook (#50518)
add 0faa0cc6252 Add dates for Limited Maintenance & EOL for Airflow 2.x
(#50794)
add 26422475c68 Chart: add missing replicas api server parameter to
values.yaml (#50814)
add bca010b3a83 Fetch only the most recent dagrun value for list display.
(#50834)
add d80a7119edf Bump `uv` to 0.7.7 (#50985)
add e23f980acda Add branch name to notify slack bot (#50997)
add 98f918150e7 Mask secrets when retrieving variables from secrets
backend (#50895)
add 8b21b13f190 fix(airflowctl): fix pre-commit for command images (#50986)
add ed671144ca8 Docs `assets.rst`: use `AssetAlias` for alias in
`Metadata` example (#50768)
add 341ab096c64 Restore `short` traceback for pytest failures (#51001)
add fb37f959ed1 Initial version of the Golang Task SDK for Apache Airflow
(#50964)
add 96ebf2909f1 Add backcompat shim and deprecation warning for
EmailOperator (#51004)
add 1e794180668 Merging `TimeSensorAsync` with `TimeSensor` (#50864)
add 6c23ee403a9 Chart: Add EdgeExecutor to schema (#50897)
add 19e0f45cdfb Force golang version to be 1.24.0 in pre-commit (#51015)
add e2c9415f6fc Chart: Add EdgeExecutor to readme (#51017)
add 95d68faedb7 Chart: Declare missing API server properties (#51012)
add 7453b183304 Add German UI translation (#50929)
add 0812f3ff2cc Chart: Add extra secret annotations to most secrets
(#48890)
add 13e79e8fe0d Remove Airflow 2 code path in executors (#51009)
add be4a4e404fd AIP-38 feat: add Korean language UI (#50981)
add 6b0f5576e5b Adding CODEOWNERS for go sdk (#51025)
add a5c47200afa fix airflow core directory in
run_generate_migration(#51024)
add 130cd464daf Run image verification in isolated environments (#51029)
add 958f77fbb13 Fix CI status badge (#51032)
add 47e4fe6926f Link pool state bar to filter taskinstances for the pool
by state. (#51031)
add 84769be6a1c Also display languages in current language not in target
language name (#51034)
add eb7c346dd0d Bugfix/fix latest pypi version check (#51039)
add 422388f1bcb Bump UV to 0.7.8 (#51040)
add beb7b629161 Prevent CPU spike in task supervisor when heartbeat
timeout exceeded (#51023)
add e7a90d65161 Bugfix Breeze BetterChoice with newer click versions
(#51051)
add 6fd1976b56a Bump golang.org/x/net from 0.33.0 to 0.38.0 in /go-sdk
(#51007)
add 1fc41b29eeb feat(api): decouple non-route methods (#51028)
add 7bd29f4e70a Add breeze commands for gh workflow docs publish (#51036)
add 6fb84a40320 Adding missing bracket to README (#51072)
add e79b034173b Add shortcut to clear and mark state for taskinstance and
dagrun. (#50885)
add 850ba8efa15 Add GitHub Actions workflow for Go SDK (#51071)
add 0478f6989f1 Merge branch 'main' into sumit/update_api
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 5 +
.editorconfig | 4 +
.github/CODEOWNERS | 8 +
.github/ISSUE_TEMPLATE/1-airflow_bug_report.yml | 2 +-
.github/actions/install-pre-commit/action.yml | 2 +-
.github/actions/migration_tests/action.yml | 4 +-
.github/boring-cyborg.yml | 3 +
.github/workflows/ci-amd.yml | 33 +-
.github/workflows/ci-arm.yml | 21 +-
.github/workflows/go-sdk-tests.yml | 68 +
.github/workflows/publish-docs-to-s3.yml | 4 +-
.github/workflows/run-unit-tests.yml | 2 +-
.pre-commit-config.yaml | 73 +-
.rat-excludes | 7 +
AGENTS.md | 47 +
Dockerfile | 4 +-
Dockerfile.ci | 8 +-
README.md | 6 +-
RELEASE_NOTES.rst | 5424 +-------------------
.../logging-monitoring/logging-tasks.rst | 2 +-
.../docs/administration-and-deployment/plugins.rst | 4 -
.../docs/authoring-and-scheduling/assets.rst | 2 +-
.../docs/authoring-and-scheduling/deferring.rst | 4 +-
airflow-core/docs/best-practices.rst | 3 +-
airflow-core/docs/cli-and-env-variables-ref.rst | 2 +-
airflow-core/docs/configurations-ref.rst | 2 +-
airflow-core/docs/extra-packages-ref.rst | 2 +
airflow-core/docs/howto/docker-compose/index.rst | 12 +-
airflow-core/docs/howto/dynamic-dag-generation.rst | 3 +-
airflow-core/docs/howto/set-config.rst | 4 +-
.../docs/installation/supported-versions.rst | 2 +-
.../docs/installation/upgrading_to_airflow3.rst | 12 +-
airflow-core/docs/public-airflow-interface.rst | 9 +-
airflow-core/docs/tutorial/taskflow.rst | 5 +-
.../auth/managers/simple/ui/package-lock.json | 2161 +++-----
.../auth/managers/simple/ui/package.json | 22 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 2052 +++-----
.../airflow/api_fastapi/common/db/task_instance.py | 57 +
.../src/airflow/api_fastapi/core_api/app.py | 2 +-
.../api_fastapi/core_api/datamodels/dag_run.py | 2 +-
.../api_fastapi/core_api/datamodels/dags.py | 2 +-
.../api_fastapi/core_api/datamodels/ui/config.py | 6 -
.../api_fastapi/core_api/openapi/_private_ui.yaml | 30 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 6 +-
.../api_fastapi/core_api/routes/public/config.py | 30 +-
.../api_fastapi/core_api/routes/public/log.py | 32 +-
.../core_api/routes/public/providers.py | 19 +-
.../core_api/routes/public/variables.py | 6 +-
.../api_fastapi/core_api/routes/ui/config.py | 18 +-
.../src/airflow/api_fastapi/core_api/security.py | 24 +-
.../api_fastapi/core_api/services/public/config.py | 47 +
.../core_api/services/public/providers.py | 25 +-
.../execution_api/routes/task_instances.py | 20 +-
airflow-core/src/airflow/cli/cli_config.py | 6 -
.../src/airflow/cli/commands/config_command.py | 63 +-
.../src/airflow/cli/commands/task_command.py | 61 +-
airflow-core/src/airflow/cli/utils.py | 5 +-
.../src/airflow/config_templates/config.yml | 112 +-
airflow-core/src/airflow/configuration.py | 7 +
.../example_passing_params_via_test_command.py | 7 +-
.../airflow/example_dags/tutorial_objectstorage.py | 62 +-
.../src/airflow/executors/base_executor.py | 271 +-
.../src/airflow/jobs/scheduler_job_runner.py | 27 +-
airflow-core/src/airflow/macros/__init__.py | 2 +-
airflow-core/src/airflow/models/dag.py | 4 +-
airflow-core/src/airflow/models/dagrun.py | 9 +-
airflow-core/src/airflow/models/deadline.py | 3 +
airflow-core/src/airflow/models/expandinput.py | 13 +-
airflow-core/src/airflow/models/taskinstance.py | 875 +---
airflow-core/src/airflow/operators/__init__.py | 3 +
airflow-core/src/airflow/plugins_manager.py | 4 +-
.../airflow/serialization/serialized_objects.py | 4 +-
airflow-core/src/airflow/ui/.prettierignore | 1 +
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 41 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 8 +-
airflow-core/src/airflow/ui/package.json | 3 +
airflow-core/src/airflow/ui/pnpm-lock.yaml | 69 +
.../ui/src/components/Assets/AssetEvent.tsx | 12 +-
.../ui/src/components/Assets/AssetEvents.tsx | 10 +-
.../ui/src/components/Assets/TriggeredRuns.tsx | 8 +-
.../ui/src/components/Clear/Run/ClearRunButton.tsx | 37 +-
.../Clear/TaskInstance/ClearTaskInstanceButton.tsx | 41 +-
.../src/components/DataTable/useTableUrlState.ts | 14 +-
.../src/components/FlexibleForm/FlexibleForm.tsx | 36 +-
.../src/components/MarkAs/Run/MarkRunAsButton.tsx | 75 +-
.../TaskInstance/MarkTaskInstanceAsButton.tsx | 75 +-
.../src/airflow/ui/src/components/PoolBar.tsx | 85 +-
.../ui/src/components/TimeRangeSelector.tsx | 27 +-
.../src/components/TriggerDag/TriggerDAGModal.tsx | 17 +-
.../src/airflow/ui/src/constants/searchParams.ts | 1 +
airflow-core/src/airflow/ui/src/i18n/config.ts | 86 +
.../src/airflow/ui/src/i18n/locales/de/common.json | 79 +
.../airflow/ui/src/i18n/locales/de/dashboard.json | 38 +
.../src/airflow/ui/src/i18n/locales/en/common.json | 79 +
.../airflow/ui/src/i18n/locales/en/dashboard.json | 38 +
.../src/airflow/ui/src/i18n/locales/ko/common.json | 79 +
.../airflow/ui/src/i18n/locales/ko/dashboard.json | 38 +
.../airflow/ui/src/i18n/locales/zh_TW/common.json | 69 +
.../ui/src/i18n/locales/zh_TW/dashboard.json | 28 +
.../src/airflow/ui/src/layouts/Nav/AdminButton.tsx | 8 +-
.../airflow/ui/src/layouts/Nav/BrowseButton.tsx | 12 +-
.../src/airflow/ui/src/layouts/Nav/DocsButton.tsx | 21 +-
.../src/airflow/ui/src/layouts/Nav/Nav.tsx | 6 +-
.../src/airflow/ui/src/layouts/Nav/PluginMenus.tsx | 4 +-
.../ui/src/layouts/Nav/UserSettingsButton.tsx | 48 +-
airflow-core/src/airflow/ui/src/main.tsx | 22 +-
.../src/airflow/ui/src/mocks/handlers/config.ts | 6 -
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 3 +-
.../airflow/ui/src/pages/Dashboard/Dashboard.tsx | 4 +-
.../ui/src/pages/Dashboard/Health/Health.tsx | 16 +-
.../ui/src/pages/Dashboard/Health/HealthBadge.tsx | 14 +-
.../src/pages/Dashboard/Health/HealthSection.tsx | 59 -
.../Dashboard/HistoricalMetrics/DagRunMetrics.tsx | 63 +-
.../HistoricalMetrics/HistoricalMetrics.tsx | 4 +-
.../Dashboard/HistoricalMetrics/MetricSection.tsx | 10 +-
.../HistoricalMetrics/TaskInstanceMetrics.tsx | 71 +-
.../pages/Dashboard/PoolSummary/PoolSummary.tsx | 6 +-
.../src/pages/Dashboard/Stats/DAGImportErrors.tsx | 7 +-
.../pages/Dashboard/Stats/DAGImportErrorsModal.tsx | 10 +-
.../airflow/ui/src/pages/Dashboard/Stats/Stats.tsx | 12 +-
.../ui/src/pages/Dashboard/Stats/StatsCard.tsx | 3 +-
.../src/airflow/ui/src/pages/Run/Details.tsx | 2 +-
.../src/airflow/ui/src/pages/Run/Header.tsx | 4 +-
.../airflow/ui/src/pages/TaskInstance/Header.tsx | 12 +-
.../ui/src/pages/TaskInstances/TaskInstances.tsx | 4 +
.../src/airflow/ui/src/queries/useDags.tsx | 3 +-
.../src/airflow/ui/src/queries/useParamStore.ts | 4 +-
.../src/airflow/utils/log/file_task_handler.py | 10 +-
airflow-core/src/airflow/utils/serve_logs.py | 2 +-
.../unit/api_fastapi/common/db}/__init__.py | 0
.../api_fastapi/common/db/test_task_instance.py | 79 +
.../core_api/routes/public/test_dag_report.py | 8 +-
.../core_api/routes/public/test_variables.py | 105 +-
.../api_fastapi/core_api/routes/ui/test_config.py | 15 +-
.../unit/api_fastapi/execution_api/conftest.py | 31 +-
.../versions/head/test_task_instances.py | 141 +-
.../unit/cli/commands/test_connection_command.py | 33 +
.../tests/unit/cli/commands/test_task_command.py | 21 +-
airflow-core/tests/unit/core/test_configuration.py | 13 +-
.../tests/unit/dag_processing/test_collection.py | 42 +-
.../tests/unit/executors/test_base_executor.py | 155 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 15 +-
.../tests/unit/listeners/test_listeners.py | 20 +-
airflow-core/tests/unit/models/test_dagbag.py | 17 +-
.../tests/unit/models/test_taskinstance.py | 1811 +------
.../tests/unit/plugins/test_plugins_manager.py | 12 +-
.../deps/test_not_previously_skipped_dep.py | 6 +-
airflow-core/tests/unit/utils/test_log_handlers.py | 2 +
airflow-ctl/docs/images/command_hashes.txt | 28 +-
airflow-ctl/docs/images/output_assets.svg | 72 +-
airflow-ctl/docs/images/output_auth.svg | 60 +-
airflow-ctl/docs/images/output_auth_login.svg | 72 +-
airflow-ctl/docs/images/output_backfills.svg | 80 +-
airflow-ctl/docs/images/output_config.svg | 56 +-
airflow-ctl/docs/images/output_connections.svg | 80 +-
airflow-ctl/docs/images/output_dag.svg | 104 +-
airflow-ctl/docs/images/output_dagrun.svg | 60 +-
airflow-ctl/docs/images/output_jobs.svg | 52 +-
airflow-ctl/docs/images/output_main.svg | 112 +-
airflow-ctl/docs/images/output_pools.svg | 68 +-
airflow-ctl/docs/images/output_providers.svg | 52 +-
airflow-ctl/docs/images/output_variables.svg | 68 +-
airflow-ctl/docs/images/output_version.svg | 52 +-
.../src/airflowctl/api/datamodels/generated.py | 2 +-
chart/README.md | 2 +
chart/docs/index.rst | 2 +
chart/docs/installing-helm-chart-from-sources.rst | 7 +-
chart/templates/secrets/elasticsearch-secret.yaml | 4 +
chart/templates/secrets/fernetkey-secret.yaml | 3 +
chart/templates/secrets/flower-secret.yaml | 4 +
.../secrets/metadata-connection-secret.yaml | 4 +
.../secrets/pgbouncer-certificates-secret.yaml | 4 +
.../templates/secrets/pgbouncer-config-secret.yaml | 4 +
.../templates/secrets/pgbouncer-stats-secret.yaml | 4 +
chart/templates/secrets/redis-secrets.yaml | 6 +
.../secrets/result-backend-connection-secret.yaml | 4 +
.../secrets/webserver-secret-key-secret.yaml | 4 +
chart/values.schema.json | 92 +-
chart/values.yaml | 80 +-
clients/python/README.md | 455 +-
clients/python/pyproject.toml | 4 +-
clients/python/test_python_client.py | 8 +-
constraints/README.md | 2 +-
contributing-docs/08_static_code_checks.rst | 10 +-
contributing-docs/14_metadata_database_updates.rst | 2 +-
contributing-docs/testing/k8s_tests.rst | 2 +-
dev/README_RELEASE_AIRFLOW.md | 3 -
dev/README_RELEASE_PROVIDERS.md | 33 +-
dev/breeze/doc/09_release_management_tasks.rst | 35 +
dev/breeze/doc/ci/02_images.md | 2 +-
dev/breeze/doc/images/output-commands.svg | 24 +-
.../output_setup_check-all-params-in-groups.svg | 2 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 28 +-
.../output_setup_regenerate-command-images.txt | 2 +-
dev/breeze/doc/images/output_static-checks.svg | 102 +-
dev/breeze/doc/images/output_static-checks.txt | 2 +-
.../doc/images/output_testing_core-tests.txt | 2 +-
.../doc/images/output_testing_providers-tests.txt | 2 +-
dev/breeze/doc/images/output_workflow-run.svg | 103 +
dev/breeze/doc/images/output_workflow-run.txt | 1 +
.../images/output_workflow-run_publish-docs.svg | 174 +
.../images/output_workflow-run_publish-docs.txt | 1 +
dev/breeze/src/airflow_breeze/breeze.py | 2 +
.../commands/release_management_commands.py | 6 +-
.../airflow_breeze/commands/testing_commands.py | 5 +-
.../airflow_breeze/commands/workflow_commands.py | 164 +
.../commands/workflow_commands_config.py | 38 +-
.../src/airflow_breeze/configure_rich_click.py | 5 +-
dev/breeze/src/airflow_breeze/global_constants.py | 10 +-
.../src/airflow_breeze/params/shell_params.py | 6 +-
dev/breeze/src/airflow_breeze/pre_commit_ids.py | 3 +
.../src/airflow_breeze/utils/custom_param_types.py | 4 +-
.../src/airflow_breeze/utils/gh_workflow_utils.py | 180 +
dev/breeze/src/airflow_breeze/utils/run_tests.py | 2 +-
.../src/airflow_breeze/utils/selective_checks.py | 16 +-
.../src/airflow_breeze/utils/version_utils.py | 4 +-
dev/breeze/tests/test_selective_checks.py | 14 +-
dev/validate_version_added_fields_in_config.py | 2 +-
devel-common/src/tests_common/pytest_plugin.py | 4 +-
.../src/tests_common/test_utils/mock_executor.py | 32 +-
.../src/tests_common/test_utils/version_compat.py | 1 +
.../test_examples_of_prod_image_building.py | 4 +-
generated/PYPI_README.md | 4 +-
generated/provider_metadata.json | 362 +-
go-sdk/README.md | 62 +
go-sdk/celery/app.go | 106 +
go-sdk/celery/cmd/root.go | 153 +
go-sdk/celery/cmd/run.go | 49 +
go-sdk/celery/config.go | 24 +
go-sdk/example/main.go | 90 +
go-sdk/go.mod | 62 +
go-sdk/go.sum | 154 +
go-sdk/pkg/api/client.gen.go | 2613 ++++++++++
go-sdk/pkg/api/client.go | 73 +
go-sdk/pkg/api/init.go | 42 +
go-sdk/pkg/api/models.go | 25 +
.../http.yaml => go-sdk/pkg/api/oapi-codegen.yml | 21 +-
go-sdk/pkg/api/overlay.yml | 68 +
go-sdk/pkg/logging/attrs.go | 29 +
go-sdk/pkg/logging/stdbridge.go | 57 +
go-sdk/pkg/logging/tee.go | 77 +
go-sdk/pkg/sdkcontext/keys.go | 35 +
go-sdk/sdk/doc.go | 21 +
go-sdk/sdk/variable.go | 43 +
go-sdk/worker/init.go | 45 +
go-sdk/worker/registry.go | 98 +
go-sdk/worker/registry_test.go | 67 +
go-sdk/worker/runner.go | 402 ++
go-sdk/worker/runner_test.go | 211 +
go-sdk/worker/task.go | 139 +
helm-tests/tests/helm_tests/other/test_flower.py | 20 +
.../tests/helm_tests/other/test_pgbouncer.py | 45 +
helm-tests/tests/helm_tests/other/test_redis.py | 33 +
.../security/test_elasticsearch_secret.py | 19 +
.../test_fernetkey_secret.py} | 22 +-
.../security/test_metadata_connection_secret.py | 16 +
.../test_result_backend_connection_secret.py | 20 +
.../tests/helm_tests/webserver/test_webserver.py | 15 +
.../test_kubernetes_pod_operator.py | 2 -
performance/requirements.txt | 2 +-
providers/amazon/docs/operators/athena/index.rst | 3 +-
providers/amazon/pyproject.toml | 9 +-
.../aws/executors/aws_lambda/lambda_executor.py | 2 +-
.../amazon/aws/executors/ecs/ecs_executor.py | 2 +-
.../aws/executors/ecs/ecs_executor_config.py | 12 +-
.../airflow/providers/amazon/aws/hooks/base_aws.py | 24 +-
.../amazon/aws/auth_manager/routes/test_login.py | 8 +-
.../aws/executors/batch/test_batch_executor.py | 1 +
.../amazon/aws/executors/ecs/test_ecs_executor.py | 1 +
providers/apache/hdfs/docs/connections.rst | 4 +-
.../airflow/providers/apache/hdfs/hooks/webhdfs.py | 8 +
.../tests/unit/apache/hdfs/hooks/test_webhdfs.py | 22 +
.../providers/celery/executors/celery_executor.py | 18 +-
.../celery/executors/celery_executor_utils.py | 13 +-
.../celery/executors/celery_kubernetes_executor.py | 16 +-
.../executors/test_celery_kubernetes_executor.py | 1 +
providers/cncf/kubernetes/docs/changelog.rst | 8 +
providers/cncf/kubernetes/provider.yaml | 4 +-
.../cncf/kubernetes/cli/kubernetes_command.py | 23 +-
.../kubernetes/executors/kubernetes_executor.py | 6 +-
.../executors/kubernetes_executor_types.py | 6 +-
.../executors/kubernetes_executor_utils.py | 13 +-
.../executors/local_kubernetes_executor.py | 16 +-
.../providers/cncf/kubernetes/get_provider_info.py | 2 +-
.../providers/cncf/kubernetes/kube_config.py | 9 +-
.../providers/cncf/kubernetes/operators/pod.py | 2 +-
.../providers/cncf/kubernetes/pod_generator.py | 77 +-
.../cncf/kubernetes/template_rendering.py | 8 +-
.../executors/test_kubernetes_executor.py | 21 +
.../kubernetes/log_handlers/test_log_handlers.py | 4 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 3 +
.../unit/cncf/kubernetes/test_pod_generator.py | 38 +-
.../cncf/kubernetes/test_template_rendering.py | 34 +-
.../tests/unit/common/sql/operators/test_sql.py | 12 +-
.../providers/edge3/executors/edge_executor.py | 10 +-
.../unit/edge3/executors/test_edge_executor.py | 3 +
providers/fab/docs/auth-manager/security.rst | 11 -
providers/fab/provider.yaml | 29 +
providers/fab/pyproject.toml | 6 +-
.../fab/src/airflow/providers/fab/__init__.py | 2 +-
.../src/airflow/providers/fab/get_provider_info.py | 28 +
providers/fab/src/airflow/providers/fab/www/app.py | 5 +-
.../fab/src/airflow/providers/fab/www/constants.py | 2 +-
.../fab/www/extensions/init_jinja_globals.py | 8 +-
.../providers/fab/www/extensions/init_security.py | 19 -
.../airflow/providers/fab/www/package-lock.json | 758 +--
.../fab/src/airflow/providers/fab/www/package.json | 6 +-
...0c838fac9e80.js => 743.1f45c836ec447657c06d.js} | 2 +-
...txt => 743.1f45c836ec447657c06d.js.LICENSE.txt} | 0
.../providers/fab/www/static/dist/manifest.json | 2 +-
providers/fab/tests/unit/fab/decorators.py | 1 -
providers/fab/www-hash.txt | 1 +
providers/google/docs/changelog.rst | 32 +-
.../providers/google/cloud/hooks/bigquery.py | 68 -
.../cloud/hooks/vertex_ai/generative_model.py | 67 +-
.../providers/google/cloud/operators/pubsub.py | 3 +-
.../cloud/operators/vertex_ai/generative_model.py | 92 -
.../google/cloud/dataflow/resources/wordcount.go | 30 +-
.../tests/unit/google/cloud/hooks/test_bigquery.py | 57 -
.../cloud/hooks/vertex_ai/test_generative_model.py | 19 -
.../operators/vertex_ai/test_generative_model.py | 63 -
.../unit/microsoft/azure/operators/test_adx.py | 25 +-
.../src/airflow/providers/mongo/hooks/mongo.py | 32 +
.../mongo/tests/unit/mongo/hooks/test_mongo.py | 31 +
providers/neo4j/pyproject.toml | 2 +-
.../tests/unit/oracle/operators/test_oracle.py | 22 +-
providers/pinecone/pyproject.toml | 2 +-
.../airflow/providers/pinecone/hooks/pinecone.py | 6 +-
.../providers/snowflake/utils/openlineage.py | 19 +-
.../unit/snowflake/decorators/test_snowpark.py | 29 +-
.../tests/unit/snowflake/utils/test_openlineage.py | 3 +
providers/standard/docs/sensors/datetime.rst | 18 +-
.../airflow/providers/standard/operators/python.py | 14 +-
.../src/airflow/providers/standard/sensors/time.py | 88 +-
.../providers/standard/sensors/time_delta.py | 3 +-
.../tests/system/standard/example_sensors.py | 15 +-
.../decorators/test_branch_external_python.py | 11 +-
.../unit/standard/decorators/test_branch_python.py | 10 +-
.../standard/decorators/test_branch_virtualenv.py | 11 +-
.../tests/unit/standard/decorators/test_python.py | 43 +-
.../unit/standard/decorators/test_short_circuit.py | 13 +-
.../standard/operators/test_branch_operator.py | 80 +-
.../tests/unit/standard/operators/test_datetime.py | 16 +-
.../operators/test_latest_only_operator.py | 8 +-
.../tests/unit/standard/operators/test_python.py | 50 +-
.../tests/unit/standard/operators/test_weekday.py | 21 +-
.../tests/unit/standard/sensors/test_time.py | 67 +-
pyproject.toml | 11 +-
reproducible_build.yaml | 4 +-
scripts/ci/airflow_version_check.py | 5 +-
.../{ci-uv-tests.yml => ci-tests.yml} | 4 +-
scripts/ci/install_breeze.sh | 2 +-
scripts/ci/pre_commit/capture_airflowctl_help.py | 105 +-
scripts/ci/pre_commit/check_deferrable_default.py | 4 +-
scripts/ci/pre_commit/common_precommit_utils.py | 2 -
scripts/ci/pre_commit/compile_fab_assets.py | 16 +-
...astapi_api_spec.py => generate_openapi_spec.py} | 2 +-
...pi_api_spec.py => generate_openapi_spec_fab.py} | 2 +-
scripts/ci/pre_commit/supported_versions.py | 2 +-
.../ci/pre_commit/update_airflow_pyproject_toml.py | 2 +-
.../pre_commit/update_installers_and_pre_commit.py | 4 +-
scripts/ci/testing/run_unit_tests.sh | 11 +
scripts/docker/entrypoint_ci.sh | 4 +-
scripts/in_container/in_container_utils.py | 51 +
.../run_capture_airflowctl_help.py} | 24 +-
scripts/in_container/run_generate_migration.sh | 2 +-
...pi_api_spec.py => run_generate_openapi_spec.py} | 73 +-
.../run_generate_openapi_spec_fab.py} | 40 +-
scripts/tools/setup_breeze | 2 +-
setup_idea.py | 1 +
task-sdk/src/airflow/sdk/definitions/dag.py | 13 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 2 +-
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 4 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 13 +-
.../sdk/{definitions => execution_time}/macros.py | 0
.../src/airflow/sdk/execution_time/supervisor.py | 8 +-
.../src/airflow/sdk/execution_time/task_runner.py | 2 +-
task-sdk/tests/task_sdk/definitions/test_macros.py | 2 +-
.../tests/task_sdk/definitions/test_variables.py | 45 +
.../tests/task_sdk/execution_time/test_context.py | 77 +-
.../task_sdk/execution_time/test_supervisor.py | 133 +-
382 files changed, 12250 insertions(+), 14848 deletions(-)
create mode 100644 .github/workflows/go-sdk-tests.yml
create mode 100644 AGENTS.md
create mode 100644
airflow-core/src/airflow/api_fastapi/common/db/task_instance.py
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/services/public/config.py
copy task-sdk/tests/task_sdk/dags/super_basic_deferred_run.py =>
airflow-core/src/airflow/api_fastapi/core_api/services/public/providers.py (63%)
create mode 100644 airflow-core/src/airflow/ui/src/i18n/config.ts
create mode 100644 airflow-core/src/airflow/ui/src/i18n/locales/de/common.json
create mode 100644
airflow-core/src/airflow/ui/src/i18n/locales/de/dashboard.json
create mode 100644 airflow-core/src/airflow/ui/src/i18n/locales/en/common.json
create mode 100644
airflow-core/src/airflow/ui/src/i18n/locales/en/dashboard.json
create mode 100644 airflow-core/src/airflow/ui/src/i18n/locales/ko/common.json
create mode 100644
airflow-core/src/airflow/ui/src/i18n/locales/ko/dashboard.json
create mode 100644
airflow-core/src/airflow/ui/src/i18n/locales/zh_TW/common.json
create mode 100644
airflow-core/src/airflow/ui/src/i18n/locales/zh_TW/dashboard.json
delete mode 100644
airflow-core/src/airflow/ui/src/pages/Dashboard/Health/HealthSection.tsx
copy airflow-core/{src/airflow/api =>
tests/unit/api_fastapi/common/db}/__init__.py (100%)
create mode 100644
airflow-core/tests/unit/api_fastapi/common/db/test_task_instance.py
create mode 100644 dev/breeze/doc/images/output_workflow-run.svg
create mode 100644 dev/breeze/doc/images/output_workflow-run.txt
create mode 100644 dev/breeze/doc/images/output_workflow-run_publish-docs.svg
create mode 100644 dev/breeze/doc/images/output_workflow-run_publish-docs.txt
create mode 100644 dev/breeze/src/airflow_breeze/commands/workflow_commands.py
copy airflow-ctl/src/airflowctl/__main__.py =>
dev/breeze/src/airflow_breeze/commands/workflow_commands_config.py (59%)
create mode 100644 dev/breeze/src/airflow_breeze/utils/gh_workflow_utils.py
create mode 100644 go-sdk/README.md
create mode 100644 go-sdk/celery/app.go
create mode 100644 go-sdk/celery/cmd/root.go
create mode 100644 go-sdk/celery/cmd/run.go
create mode 100644 go-sdk/celery/config.go
create mode 100644 go-sdk/example/main.go
create mode 100644 go-sdk/go.mod
create mode 100644 go-sdk/go.sum
create mode 100644 go-sdk/pkg/api/client.gen.go
create mode 100644 go-sdk/pkg/api/client.go
create mode 100644 go-sdk/pkg/api/init.go
create mode 100644 go-sdk/pkg/api/models.go
copy
providers/openlineage/tests/unit/openlineage/plugins/openlineage_configs/http.yaml
=> go-sdk/pkg/api/oapi-codegen.yml (65%)
create mode 100644 go-sdk/pkg/api/overlay.yml
create mode 100644 go-sdk/pkg/logging/attrs.go
create mode 100644 go-sdk/pkg/logging/stdbridge.go
create mode 100644 go-sdk/pkg/logging/tee.go
create mode 100644 go-sdk/pkg/sdkcontext/keys.go
create mode 100644 go-sdk/sdk/doc.go
create mode 100644 go-sdk/sdk/variable.go
create mode 100644 go-sdk/worker/init.go
create mode 100644 go-sdk/worker/registry.go
create mode 100644 go-sdk/worker/registry_test.go
create mode 100644 go-sdk/worker/runner.go
create mode 100644 go-sdk/worker/runner_test.go
create mode 100644 go-sdk/worker/task.go
copy helm-tests/tests/helm_tests/{other/test_limit_ranges.py =>
security/test_fernetkey_secret.py} (62%)
rename
providers/fab/src/airflow/providers/fab/www/static/dist/{743.4d8bb3a60c838fac9e80.js
=> 743.1f45c836ec447657c06d.js} (99%)
rename
providers/fab/src/airflow/providers/fab/www/static/dist/{743.4d8bb3a60c838fac9e80.js.LICENSE.txt
=> 743.1f45c836ec447657c06d.js.LICENSE.txt} (100%)
create mode 100644 providers/fab/www-hash.txt
rename scripts/ci/docker-compose/{ci-uv-tests.yml => ci-tests.yml} (93%)
copy scripts/ci/pre_commit/{update_fastapi_api_spec.py =>
generate_openapi_spec.py} (93%)
rename scripts/ci/pre_commit/{update_fastapi_api_spec.py =>
generate_openapi_spec_fab.py} (93%)
copy scripts/{ci/pre_commit/capture_airflowctl_help.py =>
in_container/run_capture_airflowctl_help.py} (83%)
mode change 100755 => 100644
rename scripts/in_container/{run_update_fastapi_api_spec.py =>
run_generate_openapi_spec.py} (52%)
copy scripts/{ci/pre_commit/check_kubeconform.py =>
in_container/run_generate_openapi_spec_fab.py} (51%)
rename task-sdk/src/airflow/sdk/{definitions => execution_time}/macros.py
(100%)
