This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/ui/chakra-ui-788431b67f
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit cfdad662f2c Bump @chakra-ui/react
add 38c50f5b54e Explicitly initialize Task SDK Stats in API server
lifespan (hardening; backport fix for 3.2.x) (#68078)
add 79fa1654d8f made await_pod_start to run before
await_init_containers_completion (#68450)
add 56699a8aa88 Add team name in asset graph view (#68457)
add 8ecd4b8bb4b Bump the auth-ui-package-updates group across 1 directory
with 5 updates (#68465)
add 44d9bfa77b0 Remove `workers` section deprecation & simplify Workers
Sets template logic (#66671)
add b64b28f92e3 Bump the github-actions-updates group across 1 directory
with 4 updates (#68470)
add 6b01a04c2f5 docs: Explain the agent tool boundary in common.ai
security docs (#68404)
add 1c40bfb27ec Access AgentRunResult.usage as a property in common.ai
logging (#68405)
add e36fab0095c Create documentation for `allow_consumer_teams` parameter
in asset access control (#66821)
add 2d1aaab9ec0 Use pre-commit hook to keep Java versions in sync (#68448)
add ab2851bc745 Return a 422 when the database rejects an API payload
(#66888)
add f0684b04ccc Revert "Explicitly initialize Task SDK Stats in API server
lifespan (hardenin…" (#68481)
add 31e1d87e129 Split e2e test-helpers.ts into domain-scoped modules
(#66387)
add b7f03406b06 Move JDK installation to image-build time (#68485)
add 0823e7ad189 Fix flaky SimpleAuthManager login tests under parallel
runs (#68498)
add e5bf1e30c1b fix(test_wasb.py): SAS token tests failing with
azure-storage-blob 12.30.0 (#68490)
add 1caab087e5c Complete missing Arabic translations (#68425)
add d5a8294de66 Add regression test for KPO awaiting pod start before
init-container logs (#68503)
add b935b90c5b4 Remove redundant tests from airflow-core (#68513)
add d08a365fe6a Update hungarian translations (#68385)
add fce62f6aae8 Add missing Polish (pl) UI translations (#68410)
add 4f2b0b3faab Magpie: sync setup bootstrap docs + pin triage feedback
channel (#68420)
add 247551da1d0 Add CI duration trend monitor to warn on slow main builds
(#68368)
add 8e4b7500e55 Explicitly initialize Stats in API server lifespan (#68514)
add ec3f008f0b1 Return dag-specified results in dag run wait API (#64577)
add 9101aa66754 Stop exposing trigger kwargs in the REST API response
(#67868)
add be617e7350c Don't auto-add Java SDK Javadoc to provider-list doc
publishes (#68237)
add bfecc03a274 Use paths to fix baseUrl deprecation warning in tsconfig
which helps in using typescript 7 preview. (#68320)
add 74a52cf5d3d Rename task_store/asset_store to
task_state_store/asset_state_store (#68438)
add 10136e51e4a Bump the edge-ui-package-updates group across 1 directory
with 14 updates (#68469)
add c6cb72c208c Make pod patching logic explicitly reflect when a pod is
retained (#68507)
add 9be3dc1860d Document and test xcom_pull run_id usage for triggered DAG
runs (#63030)
add cb7c347d81f Skip FK-referenced dag_version rows during db clean
(#68339)
add 4dc98451ba8 fix: handle unmapped task deadlock when upstream tasks are
removed (#62034)
add 06d4b1ea7d6 Emit dag_processing.last_run.seconds_ago as a tagged
metric (#62487)
add 49ef2f890b8 Avoid N+1 queries when bulk deleting variables (#68508)
add bede83ae390 Fix UI instance name title on non-Dag pages (#68288)
add 9ce71fd2270 Add additional task instance attributes to task instance's
details section (#68378)
add 1a6bfd8753c Unify Dag Code tab toolbar with Logs toolbar style (#68449)
add b9fc11c8ea4 Cleaning up some task_state and asset_state references in
core airflow (#68428)
add 3baec70f90f Renaming old name: task_state to task_store across spark
provider (#68430)
add cad58b72218 Update task_state/asset_state occurences in config.yml
(#68553)
add 05f00d654ae Cleaning up asset_state references in task sdk (#68429)
add 452fed808f6 Block retry_policy argument for StubOperator (#68551)
add 2cc74161a92 Make `example_task_state_store` use minimal context
(#68556)
add 28006a524c0 Add crash recovery ability to SparkSubmitOperator against
Kubernetes (#68067)
add 0e729051dc0 Make task and asset store row size limits configurable
(#68133)
add 2217dbc7d73 Backfill partitioned Dags by partition-date range (#67537)
add 1dc71d8b9b5 fix: fix missing rename in test_spark_submit (#68565)
add 91cce6484ce Escape URL for DagOperations lookup in task sdk client
(#68129)
add 14ab6a03ca7 Add Deadline in Dashboard Page (#68038)
add e09ad45c785 Refresh bundle version in place when DAG serialization is
unchanged (#68336)
add 774b5b50e96 Determine latest Dag version by version_number, not
created_at (#68389)
add 6783f4f7483 Fix airflow partitions clear date range for non-UTC
partitioned timetables (#68460)
add dc9abd4c028 Document apache-airflow-mypy package in core docs (#68561)
add 61f87adf525 feat: fill Taiwanese Mandarin translation gap (#68563)
add 92f1aa3edf4 Reload serialized Dag when a version is updated in place
(#68558)
add 88a1b329a0e Validate partition keys are non-empty and within column
length (#68443)
add 362cc1637a3 Fix Dag run partition key filter breaking on composite
keys with | (#68459)
add 6efd2185859 Fix `DataprocCreateBatchOperator` stuck in deferred state
for a long time (#67638)
add 6f5172b7703 Informatica provider: Add SQL auto-lineage and selective
lineage control (#66612)
add 3576a71ef15 Bump eslint-plugin-unicorn (#68467)
add 2cc26a96ba2 Bump UI dependencies to remove dependabot alarms in core,
esbuild (#68516)
add fcd079a4796 Bump @chakra-ui/react
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 (cfdad662f2c)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/chakra-ui-788431b67f
(fcd079a4796)
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:
.agents/skills/magpie-setup/adopt.md | 49 +
.agents/skills/magpie-setup/unadopt.md | 12 +-
.agents/skills/magpie-setup/upgrade.md | 10 +
.agents/skills/magpie-setup/verify.md | 31 +
.apache-magpie-overrides/pr-management-config.md | 7 +
.github/workflows/additional-ci-image-checks.yml | 2 +-
.github/workflows/additional-prod-image-tests.yml | 8 +-
.github/workflows/airflow-distributions-tests.yml | 2 +-
.github/workflows/airflow-e2e-tests.yml | 2 +-
.github/workflows/asf-allowlist-check.yml | 2 +-
.github/workflows/backport-cli.yml | 2 +-
.github/workflows/basic-tests.yml | 22 +-
.github/workflows/ci-amd.yml | 23 +-
.github/workflows/ci-arm.yml | 23 +-
...ky-tests-report.yml => ci-duration-monitor.yml} | 29 +-
.github/workflows/ci-image-build.yml | 2 +-
.github/workflows/ci-image-checks.yml | 12 +-
.github/workflows/ci-notification.yml | 2 +-
.github/workflows/codeql-analysis.yml | 13 +-
.github/workflows/e2e-flaky-tests-report.yml | 2 +-
.github/workflows/finalize-tests.yml | 6 +-
.github/workflows/generate-constraints.yml | 2 +-
.github/workflows/helm-tests.yml | 4 +-
.github/workflows/integration-system-tests.yml | 6 +-
.github/workflows/k8s-tests.yml | 2 +-
.github/workflows/milestone-tag-assistant.yml | 2 +-
.github/workflows/notify-uv-lock-conflicts.yml | 2 +-
.github/workflows/prod-image-build.yml | 4 +-
.github/workflows/publish-docs-to-s3.yml | 26 +-
.github/workflows/push-image-cache.yml | 4 +-
.github/workflows/registry-backfill.yml | 8 +-
.github/workflows/registry-build.yml | 4 +-
.github/workflows/registry-tests.yml | 4 +-
.github/workflows/release_dockerhub_image.yml | 2 +-
.../workflows/release_single_dockerhub_image.yml | 4 +-
.github/workflows/run-unit-tests.yml | 2 +-
.../scheduled-verify-release-calendar.yml | 2 +-
.github/workflows/test-providers.yml | 4 +-
.github/workflows/ui-e2e-tests.yml | 2 +-
.../update-constraints-on-push-stable.yml | 8 +-
.github/workflows/update-constraints-on-push.yml | 8 +-
.github/workflows/upgrade-check.yml | 2 +-
.pre-commit-config.yaml | 14 +
Dockerfile | 20 +
Dockerfile.ci | 25 +-
.../docs/administration-and-deployment/index.rst | 4 +-
....rst => task-and-asset-state-store-cleanup.rst} | 20 +-
...et-store.rst => task-and-asset-state-store.rst} | 36 +-
.../docs/authoring-and-scheduling/assets.rst | 18 +-
airflow-core/docs/best-practices.rst | 10 +
.../{asset-store.rst => asset-state-store.rst} | 70 +-
airflow-core/docs/core-concepts/backfill.rst | 26 +-
airflow-core/docs/core-concepts/index.rst | 8 +-
airflow-core/docs/core-concepts/multi-team.rst | 262 ++-
.../docs/core-concepts/resumable-tasks.rst | 10 +-
...et-store.rst => task-and-asset-state-store.rst} | 26 +-
.../{task-store.rst => task-state-store.rst} | 80 +-
airflow-core/docs/core-concepts/xcoms.rst | 10 +
airflow-core/docs/howto/index.rst | 1 +
airflow-core/docs/howto/static-type-checking.rst | 75 +
airflow-core/docs/migrations-ref.rst | 2 +-
airflow-core/newsfragments/62487.significant.rst | 1 +
airflow-core/newsfragments/67868.bugfix.rst | 1 +
airflow-core/src/airflow/api_fastapi/app.py | 24 +
.../auth/managers/simple/ui/package.json | 15 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 601 ++----
.../src/airflow/api_fastapi/common/exceptions.py | 54 +-
.../src/airflow/api_fastapi/common/parameters.py | 41 +-
.../{asset_store.py => asset_state_store.py} | 35 +-
.../{task_store.py => task_state_store.py} | 37 +-
.../api_fastapi/core_api/datamodels/trigger.py | 22 +-
.../api_fastapi/core_api/datamodels/ui/common.py | 1 +
.../api_fastapi/core_api/openapi/_private_ui.yaml | 27 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 383 ++--
.../api_fastapi/core_api/routes/public/__init__.py | 8 +-
.../{asset_store.py => asset_state_store.py} | 112 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 24 +-
.../public/{task_store.py => task_state_store.py} | 122 +-
.../core_api/services/public/dag_run.py | 25 +-
.../core_api/services/public/task_instances.py | 8 +-
.../core_api/services/public/variables.py | 19 +-
.../core_api/services/ui/dependencies.py | 21 +
.../{asset_store.py => asset_state_store.py} | 8 +-
.../{task_store.py => task_state_store.py} | 8 +-
.../api_fastapi/execution_api/routes/__init__.py | 10 +-
.../{asset_store.py => asset_state_store.py} | 80 +-
.../execution_api/routes/task_instances.py | 46 +-
.../routes/{task_store.py => task_state_store.py} | 36 +-
.../api_fastapi/execution_api/versions/__init__.py | 4 +-
.../execution_api/versions/v2026_06_16.py | 4 +-
airflow-core/src/airflow/cli/cli_config.py | 28 +-
.../src/airflow/cli/commands/partition_command.py | 24 +-
.../airflow/cli/commands/state_store_command.py | 12 +-
.../src/airflow/config_templates/config.yml | 22 +-
airflow-core/src/airflow/dag_processing/manager.py | 14 +-
...asset_store.py => example_asset_state_store.py} | 22 +-
...e_task_store.py => example_task_state_store.py} | 33 +-
airflow-core/src/airflow/exceptions.py | 4 +
.../src/airflow/jobs/scheduler_job_runner.py | 14 +-
...sk_state_store_and_asset_state_store_tables.py} | 36 +-
airflow-core/src/airflow/models/__init__.py | 4 +-
.../{asset_store.py => asset_state_store.py} | 8 +-
airflow-core/src/airflow/models/backfill.py | 39 +-
airflow-core/src/airflow/models/dag_version.py | 9 +-
airflow-core/src/airflow/models/dagbag.py | 83 +-
airflow-core/src/airflow/models/serialized_dag.py | 105 +-
.../models/{task_store.py => task_state_store.py} | 14 +-
.../src/airflow/serialization/definitions/dag.py | 68 +-
airflow-core/src/airflow/state/metastore.py | 240 +--
.../src/airflow/ti_deps/deps/trigger_rule_dep.py | 23 +-
airflow-core/src/airflow/timetables/base.py | 21 +-
airflow-core/src/airflow/timetables/trigger.py | 57 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 56 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 134 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 134 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 208 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 134 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 99 +-
.../ui/openapi-gen/requests/services.gen.ts | 198 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 229 +--
airflow-core/src/airflow/ui/package.json | 6 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 1676 +++++++--------
.../airflow/ui/public/i18n/locales/ar/admin.json | 21 +-
.../airflow/ui/public/i18n/locales/ar/assets.json | 21 +-
.../airflow/ui/public/i18n/locales/ar/browse.json | 22 +
.../airflow/ui/public/i18n/locales/ar/common.json | 90 +-
.../ui/public/i18n/locales/ar/components.json | 14 +-
.../src/airflow/ui/public/i18n/locales/ar/dag.json | 111 +-
.../airflow/ui/public/i18n/locales/ar/dags.json | 5 +
.../ui/public/i18n/locales/ar/dashboard.json | 2 +
.../airflow/ui/public/i18n/locales/ca/assets.json | 5 +-
.../src/airflow/ui/public/i18n/locales/ca/dag.json | 4 +-
.../airflow/ui/public/i18n/locales/en/assets.json | 20 +-
.../airflow/ui/public/i18n/locales/en/common.json | 7 +
.../src/airflow/ui/public/i18n/locales/en/dag.json | 24 +-
.../ui/public/i18n/locales/en/dashboard.json | 12 +
.../airflow/ui/public/i18n/locales/hu/admin.json | 9 +-
.../airflow/ui/public/i18n/locales/hu/assets.json | 15 +-
.../airflow/ui/public/i18n/locales/hu/browse.json | 18 +
.../airflow/ui/public/i18n/locales/hu/common.json | 63 +-
.../ui/public/i18n/locales/hu/components.json | 15 +-
.../src/airflow/ui/public/i18n/locales/hu/dag.json | 85 +-
.../airflow/ui/public/i18n/locales/hu/dags.json | 5 +
.../ui/public/i18n/locales/hu/dashboard.json | 2 +
.../airflow/ui/public/i18n/locales/hu/tasks.json | 2 +-
.../airflow/ui/public/i18n/locales/pl/assets.json | 14 +
.../airflow/ui/public/i18n/locales/pl/browse.json | 20 +
.../airflow/ui/public/i18n/locales/pl/common.json | 20 +-
.../ui/public/i18n/locales/pl/components.json | 3 +
.../src/airflow/ui/public/i18n/locales/pl/dag.json | 22 +
.../ui/public/i18n/locales/pl/dashboard.json | 2 +
.../ui/public/i18n/locales/zh-CN/assets.json | 5 +-
.../airflow/ui/public/i18n/locales/zh-CN/dag.json | 4 +-
.../ui/public/i18n/locales/zh-TW/assets.json | 5 +-
.../ui/public/i18n/locales/zh-TW/common.json | 13 +-
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 8 +-
.../airflow/ui/src/components/Graph/DagNode.tsx | 16 +-
.../airflow/ui/src/components/Graph/TaskNode.tsx | 13 +
.../ui/src/components/Graph/elkGraphUtils.ts | 2 +
.../ui/src/components/Graph/reactflowUtils.ts | 1 +
.../airflow/ui/src/components/ui/LazyClipboard.tsx | 5 +-
.../src/airflow/ui/src/layouts/BaseLayout.test.tsx | 111 +
.../src/airflow/ui/src/layouts/BaseLayout.tsx | 39 +-
.../src/airflow/ui/src/layouts/StorageLayout.tsx | 2 +-
.../src/airflow/ui/src/pages/Asset/AssetLayout.tsx | 6 +-
.../AddAssetStateStoreButton.tsx} | 8 +-
.../AssetStateStore.tsx} | 42 +-
.../AssetStateStoreModal.tsx} | 23 +-
.../ClearAllAssetStateStoreButton.tsx} | 29 +-
.../DeleteAssetStateStoreButton.tsx} | 23 +-
.../EditAssetStateStoreButton.tsx} | 14 +-
.../Asset/{AssetStore => AssetStateStore}/index.ts | 2 +-
.../src/airflow/ui/src/pages/Dag/Code/Code.tsx | 79 +-
.../airflow/ui/src/pages/Dashboard/Dashboard.tsx | 24 +-
.../Dashboard/Deadlines/DashboardDeadlines.tsx | 114 ++
.../src/pages/Dashboard/Deadlines/DeadlineItem.tsx | 53 +
.../pages/Dashboard/Deadlines/DeadlineSection.tsx | 85 +
.../AssetStore => Dashboard/Deadlines}/index.ts | 2 +-
.../HistoricalMetrics/HistoricalMetrics.tsx | 19 +-
.../src/pages/Dashboard/useDashboardDeadlines.ts | 69 +
.../airflow/ui/src/pages/TaskInstance/Details.tsx | 63 +-
.../src/pages/TaskInstance/Logs/TaskLogHeader.tsx | 8 +-
.../ui/src/pages/TaskInstance/TaskInstance.tsx | 2 +-
.../AddTaskStateStoreButton.tsx} | 8 +-
.../ClearAllTaskStateStoreButton.tsx} | 27 +-
.../DeleteTaskStateStoreButton.tsx} | 23 +-
.../EditTaskStateStoreButton.tsx} | 8 +-
.../TaskStateStore.tsx} | 36 +-
.../TaskStateStoreModal.tsx} | 31 +-
.../pages/{TaskStore => TaskStateStore}/index.ts | 2 +-
airflow-core/src/airflow/ui/src/router.tsx | 8 +-
.../index.ts => utils/documentTitleContext.ts} | 5 +-
airflow-core/src/airflow/ui/src/utils/index.ts | 1 +
.../src/airflow/ui/src/utils/useDocumentTitle.ts | 19 +-
...cumentTitle.ts => useDocumentTitleProvider.tsx} | 24 +-
.../airflow/ui/tests/e2e/fixtures/asset-data.ts | 2 +-
.../ui/tests/e2e/fixtures/audit-log-data.ts | 2 +-
.../airflow/ui/tests/e2e/fixtures/calendar-data.ts | 4 +-
.../airflow/ui/tests/e2e/fixtures/dag-runs-data.ts | 4 +-
.../ui/tests/e2e/fixtures/dashboard-data.ts | 2 +-
.../src/airflow/ui/tests/e2e/fixtures/data.ts | 4 +-
.../ui/tests/e2e/fixtures/task-instances-data.ts | 8 +-
.../src/airflow/ui/tests/e2e/fixtures/xcom-data.ts | 4 +-
.../src/airflow/ui/tests/e2e/global-setup.ts | 2 +-
.../src/airflow/ui/tests/e2e/pages/BackfillPage.ts | 2 +-
.../airflow/ui/tests/e2e/pages/ConnectionsPage.ts | 2 +-
.../ui/tests/e2e/pages/RequiredActionsPage.ts | 2 +-
.../airflow/ui/tests/e2e/specs/backfill.spec.ts | 4 +-
.../airflow/ui/tests/e2e/specs/connections.spec.ts | 2 +-
.../airflow/ui/tests/e2e/specs/dags-list.spec.ts | 2 +-
.../src/airflow/ui/tests/e2e/specs/pools.spec.ts | 2 +-
.../ui/tests/e2e/specs/requiredAction.spec.ts | 3 +-
.../airflow/ui/tests/e2e/specs/variable.spec.ts | 3 +-
.../airflow/ui/tests/e2e/utils/api/backfills.ts | 188 ++
.../src/airflow/ui/tests/e2e/utils/api/dag-runs.ts | 345 ++++
.../src/airflow/ui/tests/e2e/utils/api/hitl.ts | 194 ++
.../airflow/ui/tests/e2e/utils/api/variables.ts | 66 +
.../e2e/utils/shared.ts} | 34 +-
.../src/airflow/ui/tests/e2e/utils/test-helpers.ts | 802 --------
.../src/airflow/ui/tests/e2e/utils/ui/waits.ts | 64 +
airflow-core/src/airflow/ui/tsconfig.app.json | 5 +-
airflow-core/src/airflow/utils/db_cleanup.py | 52 +-
.../api_fastapi/auth/managers/simple/conftest.py | 16 +
.../unit/api_fastapi/common/test_exceptions.py | 110 +-
.../unit/api_fastapi/common/test_parameters.py | 42 +
.../core_api/datamodels/test_trigger.py | 56 +
...st_asset_store.py => test_asset_state_store.py} | 92 +-
.../core_api/routes/public/test_backfills.py | 128 ++
.../core_api/routes/public/test_dag_run.py | 154 +-
.../core_api/routes/public/test_task_instances.py | 26 +-
...test_task_store.py => test_task_state_store.py} | 128 +-
.../core_api/routes/public/test_variables.py | 26 +
.../core_api/routes/ui/test_dependencies.py | 86 +-
.../api_fastapi/core_api/routes/ui/test_grid.py | 13 +-
.../core_api/routes/ui/test_structure.py | 22 +
...st_asset_store.py => test_asset_state_store.py} | 40 +-
.../versions/head/test_task_instances.py | 145 +-
...test_task_store.py => test_task_state_store.py} | 44 +-
airflow-core/tests/unit/api_fastapi/test_app.py | 44 +
.../unit/cli/commands/test_backfill_command.py | 26 +
.../unit/cli/commands/test_kerberos_command.py | 10 -
.../unit/cli/commands/test_partition_command.py | 227 ++-
.../unit/cli/commands/test_state_store_command.py | 14 +-
.../tests/unit/dag_processing/test_manager.py | 20 +-
.../tests/unit/dag_processing/test_processor.py | 28 +-
.../tests/unit/executors/test_base_executor.py | 15 -
airflow-core/tests/unit/jobs/test_base_job.py | 10 -
airflow-core/tests/unit/jobs/test_scheduler_job.py | 2 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 28 +-
.../tests/unit/logging/test_logging_config.py | 8 -
...st_asset_store.py => test_asset_state_store.py} | 46 +-
airflow-core/tests/unit/models/test_backfill.py | 437 +++-
airflow-core/tests/unit/models/test_dag.py | 81 +-
airflow-core/tests/unit/models/test_dag_version.py | 61 +-
airflow-core/tests/unit/models/test_dagbag.py | 162 +-
airflow-core/tests/unit/models/test_dagrun.py | 121 ++
.../tests/unit/models/test_serialized_dag.py | 106 +
...test_task_store.py => test_task_state_store.py} | 56 +-
.../partition_mappers/test_rollup_wait_policy.py | 17 -
airflow-core/tests/unit/state/test_metastore.py | 213 +-
.../unit/ti_deps/deps/test_trigger_rule_dep.py | 90 +
.../unit/timetables/test_trigger_timetable.py | 238 +++
airflow-core/tests/unit/utils/test_db_cleanup.py | 95 +-
.../src/airflowctl/api/datamodels/generated.py | 44 +-
chart/files/pod-template-file.kubernetes-helm-yaml | 96 +-
chart/templates/NOTES.txt | 704 -------
chart/templates/_helpers.yaml | 48 +-
.../pgbouncer/pgbouncer-networkpolicy.yaml | 10 +-
chart/templates/rbac/job-launcher-rolebinding.yaml | 5 +-
chart/templates/rbac/pod-launcher-rolebinding.yaml | 5 +-
.../security-context-constraint-rolebinding.yaml | 5 +-
.../templates/scheduler/scheduler-deployment.yaml | 18 +-
.../secrets/metadata-connection-secret.yaml | 10 +-
chart/templates/workers/worker-deployment.yaml | 241 ++-
chart/templates/workers/worker-hpa.yaml | 29 +-
chart/templates/workers/worker-kedaautoscaler.yaml | 39 +-
.../workers/worker-kubernetes-serviceaccount.yaml | 8 +-
chart/templates/workers/worker-networkpolicy.yaml | 17 +-
.../workers/worker-poddisruptionbudget.yaml | 21 +-
chart/templates/workers/worker-service.yaml | 17 +-
chart/templates/workers/worker-serviceaccount.yaml | 20 +-
chart/tests/chart_utils/log_groomer.py | 40 +-
.../helm_tests/airflow_aux/test_airflow_common.py | 12 +-
.../helm_tests/airflow_aux/test_annotations.py | 128 --
.../airflow_aux/test_container_lifecycle.py | 159 +-
.../airflow_aux/test_job_launcher_role.py | 36 +-
.../airflow_aux/test_pod_launcher_role.py | 72 +-
.../airflow_aux/test_pod_template_file.py | 1042 +++-------
.../helm_tests/airflow_core/test_pdb_worker.py | 117 +-
.../helm_tests/airflow_core/test_scheduler.py | 101 +-
chart/tests/helm_tests/airflow_core/test_worker.py | 1721 ++++------------
.../helm_tests/airflow_core/test_worker_sets.py | 2126 +++++---------------
chart/tests/helm_tests/other/test_hpa.py | 100 +-
chart/tests/helm_tests/other/test_keda.py | 191 +-
chart/tests/helm_tests/other/test_pgbouncer.py | 24 +-
chart/tests/helm_tests/security/test_kerberos.py | 57 +-
chart/tests/helm_tests/security/test_rbac.py | 25 +-
.../helm_tests/security/test_rbac_pod_launcher.py | 7 +-
.../helm_tests/security/test_scc_rolebinding.py | 36 +-
.../helm_tests/security/test_security_context.py | 325 +--
chart/values.schema.json | 1386 +------------
chart/values.yaml | 691 +------
dev/breeze/doc/images/output_build-docs.svg | 2 +-
dev/breeze/doc/images/output_build-docs.txt | 2 +-
dev/breeze/doc/images/output_shell.svg | 16 +-
dev/breeze/doc/images/output_shell.txt | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 16 +-
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
.../src/airflow_breeze/commands/common_options.py | 2 +-
.../airflow_breeze/commands/developer_commands.py | 6 -
.../commands/developer_commands_config.py | 2 -
.../src/airflow_breeze/params/shell_params.py | 3 -
dev/breeze/tests/test_selective_checks.py | 2 +-
.../react_plugin_template/package.json | 6 +-
.../react_plugin_template/pnpm-lock.yaml | 332 +--
docs/spelling_wordlist.txt | 2 +
generated/provider_dependencies.json | 5 +-
.../main/kotlin/airflow-jvm-conventions.gradle.kts | 7 +-
providers/apache/spark/docs/changelog.rst | 2 +-
providers/apache/spark/docs/operators.rst | 11 +-
.../providers/apache/spark/hooks/spark_submit.py | 31 +-
.../apache/spark/operators/spark_submit.py | 87 +-
.../apache/spark/operators/test_spark_submit.py | 227 ++-
.../providers/cncf/kubernetes/operators/pod.py | 15 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 20 +
providers/common/ai/docs/toolsets.rst | 29 +
.../example_dags/example_aip_progress_tracker.py | 10 +-
.../common/ai/utils/dataquality}/__init__.py | 0
.../airflow/providers/common/ai/utils/logging.py | 2 +-
.../common/ai/tests/unit/common/ai/conftest.py | 6 +-
.../tests/unit/common/ai/decorators/test_agent.py | 4 +-
.../ai/tests/unit/common/ai/decorators/test_llm.py | 4 +-
.../unit/common/ai/decorators/test_llm_branch.py | 4 +-
.../common/ai/decorators/test_llm_file_analysis.py | 2 +-
.../ai/decorators/test_llm_schema_compare.py | 4 +-
.../unit/common/ai/decorators/test_llm_sql.py | 4 +-
.../tests/unit/common/ai/operators/test_agent.py | 4 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 4 +-
.../unit/common/ai/operators/test_llm_branch.py | 4 +-
.../common/ai/operators/test_llm_file_analysis.py | 2 +-
.../common/ai/operators/test_llm_schema_compare.py | 4 +-
.../tests/unit/common/ai/operators/test_llm_sql.py | 4 +-
.../ai/tests/unit/common/ai/utils/test_logging.py | 2 +-
.../providers/edge3/plugins/www/package.json | 33 +-
.../providers/edge3/plugins/www/pnpm-lock.yaml | 886 +++-----
.../providers/google/cloud/hooks/dataproc.py | 19 +-
.../providers/google/cloud/triggers/dataproc.py | 4 +-
.../unit/google/cloud/triggers/test_dataproc.py | 35 +
providers/informatica/README.rst | 1 +
providers/informatica/dev/docker-compose.yml | 90 +
.../dev/informatica_simulator/Dockerfile | 74 +-
.../dev/informatica_simulator/app/main.py | 372 ++++
.../dev/informatica_simulator/requirements.txt | 8 +
.../informatica/dev/init/001_schema_and_seed.sql | 152 ++
providers/informatica/docs/changelog.rst | 13 +
providers/informatica/docs/guides/api.rst | 2 +-
.../informatica/docs/guides/configuration.rst | 81 +-
providers/informatica/docs/guides/usage.rst | 153 +-
providers/informatica/docs/index.rst | 2 +
providers/informatica/provider.yaml | 29 +
providers/informatica/pyproject.toml | 8 +-
.../src/airflow/providers/informatica/conf.py | 61 +
.../informatica/example_dags}/__init__.py | 0
.../example_dags/example_informatica_lineage.py | 353 ++++
.../informatica/extractors/informatica.py | 82 +-
.../providers/informatica/get_provider_info.py | 21 +
.../src/airflow/providers/informatica/hooks/edc.py | 69 +-
.../providers/informatica/lineage/__init__.py | 26 +-
.../providers/informatica/lineage/resolver.py | 161 ++
.../providers/informatica/lineage/selective.py | 68 +
.../providers/informatica/lineage/sql_parser.py | 133 ++
.../providers/informatica/lineage/validation.py | 298 +++
.../providers/informatica/plugins/informatica.py | 4 +-
.../providers/informatica/plugins/listener.py | 176 +-
.../tests/unit/informatica/hooks/test_edc.py | 91 +-
.../tests/unit/informatica/lineage}/__init__.py | 0
.../unit/informatica/lineage/test_resolver.py | 155 ++
.../unit/informatica/lineage/test_selective.py | 78 +
.../unit/informatica/lineage/test_sql_parser.py | 148 ++
.../unit/informatica/lineage/test_validation.py | 314 +++
.../unit/informatica/plugins/test_listener.py | 434 +++-
.../tests/unit/informatica/test_conf.py | 86 +
.../providers/microsoft/azure/hooks/wasb.py | 7 +-
.../tests/unit/microsoft/azure/hooks/test_wasb.py | 32 +-
.../airflow/providers/standard/decorators/stub.py | 10 +
.../tests/unit/standard/decorators/test_stub.py | 14 +
.../tests/unit/standard/operators/test_python.py | 2 +-
scripts/ci/analyze_ci_job_durations.py | 586 ++++++
scripts/ci/prek/check_java_sdk_version_in_sync.py | 152 ++
.../check_template_context_variable_in_sync.py | 6 +-
scripts/docker/entrypoint_ci.sh | 4 -
scripts/docker/install_jdk.sh | 70 -
scripts/docker/install_os_dependencies.sh | 20 +
scripts/tests/ci/test_analyze_ci_job_durations.py | 310 +++
.../observability/metrics/metrics_template.yaml | 9 +-
shared/state/src/airflow_shared/state/__init__.py | 42 +-
shared/state/tests/state/test_state.py | 54 +-
task-sdk/docs/resumable-job-mixin.rst | 8 +-
task-sdk/src/airflow/sdk/api/client.py | 37 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 32 +-
.../src/airflow/sdk/bases/resumablejobmixin.py | 26 +-
task-sdk/src/airflow/sdk/definitions/context.py | 8 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 100 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 160 +-
.../airflow/sdk/execution_time/schema/schema.json | 184 +-
.../src/airflow/sdk/execution_time/supervisor.py | 82 +-
.../src/airflow/sdk/execution_time/task_runner.py | 10 +-
task-sdk/tests/task_sdk/api/test_client.py | 79 +-
.../tests/task_sdk/bases/test_resumablejobmixin.py | 2 +-
.../tests/task_sdk/execution_time/test_context.py | 343 ++--
.../task_sdk/execution_time/test_supervisor.py | 100 +-
.../task_sdk/execution_time/test_task_runner.py | 173 +-
412 files changed, 16835 insertions(+), 14605 deletions(-)
copy .github/workflows/{e2e-flaky-tests-report.yml => ci-duration-monitor.yml}
(73%)
rename
airflow-core/docs/administration-and-deployment/{task-and-asset-store-cleanup.rst
=> task-and-asset-state-store-cleanup.rst} (70%)
rename
airflow-core/docs/administration-and-deployment/{task-and-asset-store.rst =>
task-and-asset-state-store.rst} (77%)
rename airflow-core/docs/core-concepts/{asset-store.rst =>
asset-state-store.rst} (50%)
rename airflow-core/docs/core-concepts/{task-and-asset-store.rst =>
task-and-asset-state-store.rst} (82%)
rename airflow-core/docs/core-concepts/{task-store.rst =>
task-state-store.rst} (68%)
create mode 100644 airflow-core/docs/howto/static-type-checking.rst
create mode 100644 airflow-core/newsfragments/62487.significant.rst
create mode 100644 airflow-core/newsfragments/67868.bugfix.rst
rename
airflow-core/src/airflow/api_fastapi/core_api/datamodels/{asset_store.py =>
asset_state_store.py} (61%)
rename airflow-core/src/airflow/api_fastapi/core_api/datamodels/{task_store.py
=> task_state_store.py} (67%)
rename
airflow-core/src/airflow/api_fastapi/core_api/routes/public/{asset_store.py =>
asset_state_store.py} (64%)
rename
airflow-core/src/airflow/api_fastapi/core_api/routes/public/{task_store.py =>
task_state_store.py} (73%)
rename
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/{asset_store.py
=> asset_state_store.py} (86%)
rename
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/{task_store.py =>
task_state_store.py} (87%)
rename
airflow-core/src/airflow/api_fastapi/execution_api/routes/{asset_store.py =>
asset_state_store.py} (78%)
rename
airflow-core/src/airflow/api_fastapi/execution_api/routes/{task_store.py =>
task_state_store.py} (83%)
rename airflow-core/src/airflow/example_dags/{example_asset_store.py =>
example_asset_state_store.py} (81%)
rename airflow-core/src/airflow/example_dags/{example_task_store.py =>
example_task_state_store.py} (70%)
rename
airflow-core/src/airflow/migrations/versions/{0112_3_3_0_add_task_store_and_asset_store_tables.py
=> 0112_3_3_0_add_task_state_store_and_asset_state_store_tables.py} (72%)
rename airflow-core/src/airflow/models/{asset_store.py =>
asset_state_store.py} (93%)
rename airflow-core/src/airflow/models/{task_store.py => task_state_store.py}
(87%)
create mode 100644 airflow-core/src/airflow/ui/src/layouts/BaseLayout.test.tsx
rename
airflow-core/src/airflow/ui/src/pages/Asset/{AssetStore/AddAssetStoreButton.tsx
=> AssetStateStore/AddAssetStateStoreButton.tsx} (81%)
rename airflow-core/src/airflow/ui/src/pages/Asset/{AssetStore/AssetStore.tsx
=> AssetStateStore/AssetStateStore.tsx} (74%)
rename
airflow-core/src/airflow/ui/src/pages/Asset/{AssetStore/AssetStoreModal.tsx =>
AssetStateStore/AssetStateStoreModal.tsx} (84%)
rename
airflow-core/src/airflow/ui/src/pages/Asset/{AssetStore/ClearAllAssetStoreButton.tsx
=> AssetStateStore/ClearAllAssetStateStoreButton.tsx} (63%)
rename
airflow-core/src/airflow/ui/src/pages/Asset/{AssetStore/DeleteAssetStoreButton.tsx
=> AssetStateStore/DeleteAssetStateStoreButton.tsx} (72%)
rename
airflow-core/src/airflow/ui/src/pages/Asset/{AssetStore/EditAssetStoreButton.tsx
=> AssetStateStore/EditAssetStateStoreButton.tsx} (76%)
copy airflow-core/src/airflow/ui/src/pages/Asset/{AssetStore =>
AssetStateStore}/index.ts (95%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dashboard/Deadlines/DashboardDeadlines.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dashboard/Deadlines/DeadlineItem.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dashboard/Deadlines/DeadlineSection.tsx
copy airflow-core/src/airflow/ui/src/pages/{Asset/AssetStore =>
Dashboard/Deadlines}/index.ts (93%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dashboard/useDashboardDeadlines.ts
rename airflow-core/src/airflow/ui/src/pages/{TaskStore/AddTaskStoreButton.tsx
=> TaskStateStore/AddTaskStateStoreButton.tsx} (86%)
rename
airflow-core/src/airflow/ui/src/pages/{TaskStore/ClearAllTaskStoreButton.tsx =>
TaskStateStore/ClearAllTaskStateStoreButton.tsx} (67%)
rename
airflow-core/src/airflow/ui/src/pages/{TaskStore/DeleteTaskStoreButton.tsx =>
TaskStateStore/DeleteTaskStateStoreButton.tsx} (73%)
rename
airflow-core/src/airflow/ui/src/pages/{TaskStore/EditTaskStoreButton.tsx =>
TaskStateStore/EditTaskStateStoreButton.tsx} (84%)
rename airflow-core/src/airflow/ui/src/pages/{TaskStore/TaskStore.tsx =>
TaskStateStore/TaskStateStore.tsx} (79%)
rename airflow-core/src/airflow/ui/src/pages/{TaskStore/TaskStoreModal.tsx =>
TaskStateStore/TaskStateStoreModal.tsx} (88%)
rename airflow-core/src/airflow/ui/src/pages/{TaskStore =>
TaskStateStore}/index.ts (94%)
rename airflow-core/src/airflow/ui/src/{pages/Asset/AssetStore/index.ts =>
utils/documentTitleContext.ts} (83%)
copy airflow-core/src/airflow/ui/src/utils/{useDocumentTitle.ts =>
useDocumentTitleProvider.tsx} (57%)
create mode 100644 airflow-core/src/airflow/ui/tests/e2e/utils/api/backfills.ts
create mode 100644 airflow-core/src/airflow/ui/tests/e2e/utils/api/dag-runs.ts
create mode 100644 airflow-core/src/airflow/ui/tests/e2e/utils/api/hitl.ts
create mode 100644 airflow-core/src/airflow/ui/tests/e2e/utils/api/variables.ts
copy airflow-core/src/airflow/ui/{src/utils/useDocumentTitle.ts =>
tests/e2e/utils/shared.ts} (56%)
delete mode 100644 airflow-core/src/airflow/ui/tests/e2e/utils/test-helpers.ts
create mode 100644 airflow-core/src/airflow/ui/tests/e2e/utils/ui/waits.ts
create mode 100644
airflow-core/tests/unit/api_fastapi/core_api/datamodels/test_trigger.py
rename
airflow-core/tests/unit/api_fastapi/core_api/routes/public/{test_asset_store.py
=> test_asset_state_store.py} (79%)
rename
airflow-core/tests/unit/api_fastapi/core_api/routes/public/{test_task_store.py
=> test_task_state_store.py} (79%)
rename
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/{test_asset_store.py
=> test_asset_state_store.py} (92%)
rename
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/{test_task_store.py
=> test_task_state_store.py} (90%)
rename airflow-core/tests/unit/models/{test_asset_store.py =>
test_asset_state_store.py} (74%)
rename airflow-core/tests/unit/models/{test_task_store.py =>
test_task_state_store.py} (80%)
copy {airflow-core/src/airflow/_shared =>
providers/common/ai/src/airflow/providers/common/ai/utils/dataquality}/__init__.py
(100%)
create mode 100644 providers/informatica/dev/docker-compose.yml
copy airflow-core/src/airflow/api_fastapi/core_api/datamodels/trigger.py =>
providers/informatica/dev/informatica_simulator/Dockerfile (59%)
create mode 100644 providers/informatica/dev/informatica_simulator/app/main.py
create mode 100644
providers/informatica/dev/informatica_simulator/requirements.txt
create mode 100644 providers/informatica/dev/init/001_schema_and_seed.sql
create mode 100644
providers/informatica/src/airflow/providers/informatica/conf.py
copy {airflow-core/src/airflow/_shared =>
providers/informatica/src/airflow/providers/informatica/example_dags}/__init__.py
(100%)
create mode 100644
providers/informatica/src/airflow/providers/informatica/example_dags/example_informatica_lineage.py
copy airflow-core/src/airflow/api_fastapi/core_api/datamodels/trigger.py =>
providers/informatica/src/airflow/providers/informatica/lineage/__init__.py
(64%)
create mode 100644
providers/informatica/src/airflow/providers/informatica/lineage/resolver.py
create mode 100644
providers/informatica/src/airflow/providers/informatica/lineage/selective.py
create mode 100644
providers/informatica/src/airflow/providers/informatica/lineage/sql_parser.py
create mode 100644
providers/informatica/src/airflow/providers/informatica/lineage/validation.py
copy {airflow-core/tests/integration =>
providers/informatica/tests/unit/informatica/lineage}/__init__.py (100%)
create mode 100644
providers/informatica/tests/unit/informatica/lineage/test_resolver.py
create mode 100644
providers/informatica/tests/unit/informatica/lineage/test_selective.py
create mode 100644
providers/informatica/tests/unit/informatica/lineage/test_sql_parser.py
create mode 100644
providers/informatica/tests/unit/informatica/lineage/test_validation.py
create mode 100644 providers/informatica/tests/unit/informatica/test_conf.py
create mode 100644 scripts/ci/analyze_ci_job_durations.py
create mode 100644 scripts/ci/prek/check_java_sdk_version_in_sync.py
delete mode 100755 scripts/docker/install_jdk.sh
create mode 100644 scripts/tests/ci/test_analyze_ci_job_durations.py
