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/core-ui-package-updates-d53a470834
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 50cea6c6f1e Bump the core-ui-package-updates group across 1 directory
with 21 updates
add 87ffc9d4681 Doc: clarify trigger rule behavior for removed upstream
state (#67452)
add 3daecd4ce33 docs: refresh installing.md stable version examples
(#64724)
add adc3fa761da Clarify beginner quick start duration (#67302)
add 8d1c8338154 remove no need overlook test (#67230)
add 10244e310c4 Add SEC 10-K analysis example using LangChain for
Common.ai provider (#67727)
add 23cdb882dc8 Fix exceptions of positional session use in Edge provider
(2) (#67812)
add 6137c94e0e9 Add callback_execution_timeout config for deadline
callbacks (#66609)
add b9546078ba1 API: Add POST /dags/{dag_id}/clearDagRuns bulk endpoint
(#67709)
add 8607e9465b6 Fix edge executor to support handling execute callback
workload (#67679)
add 6dee0b84b88 Fix dashboard pool summary deferred slot usage (#67818)
add 24523eae721 [main] CI: Upgrade important CI environment (#67827)
add f7a2f303e32 Bump vitest in
/dev/react-plugin-tools/react_plugin_template (#67853)
add 31dded5fee0 Fix deferrable execution timeout handling for Airbyte
jobs. (#67816)
add 8f76fa01803 Empty suffix for SVN release for airflowctl (#67865)
add 89322f157de Fix flaky SSH test_command_timeout_fail on loaded CI
runners (#67829)
add 990372e256a Fix scheduler crashloop from KubernetesExecutor
completed-pod adoption (#67850)
add 17c597e3e5e `docs/dag-bundle-docs`: Adding more specific docs for
configuring DAG bundles (#67843)
add 33363d54185 fix test in main (#67861)
add d470fe7bfb0 Change default for Service Links for Chart 2.0 (#67803)
add 707e3168816 [main] Upgrade important CI environment (#67860)
add 34d9bd14205 Add preliminary coordinator and Java SDK documentation
(#67699)
add d04712b86c2 AIP-103: Allowing outlets to be added/accessed in
`AssetStateAccessor` (#67619)
add 24ff00e7d0b common-ai: Honour serialize_output=True on
LLMFileAnalysisOperator (#67858)
add 6a95da5e98d Register operator-declared XCom classes from a worker-side
DAG walk (#67875)
add 1c1cd5a1add ElasticsearchSQLHook: add Polars DataFrame support via
custom SQL reader (#66220)
add 13ce305a15d Refactor PostgresHook and associated runtime tests (#66893)
add d5eea70ce6a Fix flaky mongo provider tests: disable testcontainers
ryuk reaper in CI (#67882)
add ac6894b358a Rename task_state/asset_state to task_store/asset_store
across the codebase (#67833)
add 745898a17e5 Fail fast for non-serializable retry_args in deferrable
operators and triggers (#64960)
add 19837ed7774 Fix Task SDK docs build failing on coordinator and core
doc references (#67889)
add 4c71e37848c Avoid lazy-loading timetable fields for latest DagRuns
(#66488)
add f3d292053eb Revert "Bump @chakra-ui/react (#67734)" (#67855)
add ac73ed8c526 Bump the core-ui-package-updates group across 1 directory
with 21 updates
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 (50cea6c6f1e)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/core-ui-package-updates-d53a470834
(ac73ed8c526)
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:
.pre-commit-config.yaml | 2 +-
Dockerfile.ci | 4 +-
INSTALLING.md | 4 +-
.../administration-and-deployment/dag-bundles.rst | 94 +-
.../docs/authoring-and-scheduling/index.rst | 1 +
.../language-sdks/index.rst | 162 +++
.../language-sdks/java.rst | 360 +++++
airflow-core/docs/best-practices.rst | 2 +-
airflow-core/docs/core-concepts/dags.rst | 13 +-
airflow-core/docs/migrations-ref.rst | 2 +-
.../datamodels/{asset_state.py => asset_store.py} | 14 +-
.../api_fastapi/core_api/datamodels/dag_run.py | 26 +-
.../datamodels/{task_state.py => task_store.py} | 18 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 282 ++--
.../api_fastapi/core_api/routes/public/__init__.py | 11 +-
.../public/{asset_state.py => asset_store.py} | 80 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 175 ++-
.../routes/public/{task_state.py => task_store.py} | 122 +-
.../src/airflow/api_fastapi/core_api/security.py | 75 +-
.../core_api/services/public/dag_run.py | 106 +-
.../core_api/services/public/task_instances.py | 8 +-
.../datamodels/{asset_state.py => asset_store.py} | 8 +-
.../datamodels/{task_state.py => task_store.py} | 8 +-
.../api_fastapi/execution_api/routes/__init__.py | 8 +-
.../routes/{asset_state.py => asset_store.py} | 58 +-
.../routes/{task_state.py => task_store.py} | 36 +-
.../api_fastapi/execution_api/versions/__init__.py | 4 +-
.../execution_api/versions/v2026_06_16.py | 28 +-
airflow-core/src/airflow/cli/cli_config.py | 10 +-
.../airflow/cli/commands/state_store_command.py | 12 +-
.../src/airflow/config_templates/config.yml | 17 +-
.../src/airflow/dag_processing/collection.py | 6 +
...ample_asset_state.py => example_asset_store.py} | 25 +-
...example_task_state.py => example_task_store.py} | 24 +-
.../src/airflow/jobs/scheduler_job_runner.py | 12 +-
...3_3_0_add_task_store_and_asset_store_tables.py} | 36 +-
airflow-core/src/airflow/models/__init__.py | 4 +-
.../models/{asset_state.py => asset_store.py} | 9 +-
.../models/{task_state.py => task_store.py} | 15 +-
airflow-core/src/airflow/state/__init__.py | 14 +-
airflow-core/src/airflow/state/metastore.py | 216 +--
.../src/airflow/ui/openapi-gen/queries/common.ts | 57 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 42 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 42 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 130 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 42 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 118 +-
.../ui/openapi-gen/requests/services.gen.ts | 132 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 178 ++-
airflow-core/src/airflow/ui/package.json | 4 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 1400 ++++++++++----------
.../ui/public/i18n/locales/en/dashboard.json | 2 +
.../src/airflow/ui/src/components/PoolBar.test.tsx | 65 +
.../Dashboard/PoolSummary/PoolSummary.test.tsx | 150 +++
.../pages/Dashboard/PoolSummary/PoolSummary.tsx | 26 +-
.../tests/unit/always/test_project_structure.py | 3 -
.../{test_asset_state.py => test_asset_store.py} | 38 +-
.../core_api/routes/public/test_dag_run.py | 216 ++-
.../core_api/routes/public/test_dag_sources.py | 2 -
.../core_api/routes/public/test_task_instances.py | 18 +-
.../{test_task_state.py => test_task_store.py} | 60 +-
.../{test_asset_state.py => test_asset_store.py} | 28 +-
.../versions/head/test_task_instances.py | 18 +-
.../{test_task_state.py => test_task_store.py} | 46 +-
.../execution_api/versions/head/test_xcoms.py | 34 +-
.../unit/cli/commands/test_state_store_command.py | 14 +-
.../tests/unit/dag_processing/test_collection.py | 42 +-
.../tests/unit/dag_processing/test_processor.py | 32 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 32 +-
.../{test_asset_state.py => test_asset_store.py} | 40 +-
.../{test_task_state.py => test_task_store.py} | 54 +-
airflow-core/tests/unit/state/test_metastore.py | 116 +-
.../src/airflowctl/api/datamodels/generated.py | 70 +-
chart/files/pod-template-file.kubernetes-helm-yaml | 2 +-
chart/newsfragments/67447.significant.rst | 3 -
chart/newsfragments/67803.significant.rst | 3 +
chart/templates/NOTES.txt | 8 -
chart/templates/_helpers.yaml | 12 -
.../api-server/api-server-deployment.yaml | 2 +-
chart/templates/cleanup/cleanup-cronjob.yaml | 2 +-
.../dag-processor/dag-processor-deployment.yaml | 2 +-
.../database-cleanup/database-cleanup-cronjob.yaml | 2 +-
chart/templates/flower/flower-deployment.yaml | 2 +-
chart/templates/jobs/create-user-job.yaml | 2 +-
chart/templates/jobs/migrate-database-job.yaml | 2 +-
.../otel-collector/otel-collector-deployment.yaml | 2 +-
.../templates/pgbouncer/pgbouncer-deployment.yaml | 2 +-
chart/templates/redis/redis-statefulset.yaml | 2 +-
.../templates/scheduler/scheduler-deployment.yaml | 2 +-
chart/templates/statsd/statsd-deployment.yaml | 2 +-
.../templates/triggerer/triggerer-deployment.yaml | 2 +-
chart/templates/workers/worker-deployment.yaml | 2 +-
.../helm_tests/airflow_aux/test_airflow_common.py | 2 +-
chart/values.schema.json | 9 +-
chart/values.yaml | 2 +-
.../03a_contributors_quick_start_beginners.rst | 2 +-
dev/README_RELEASE_AIRFLOWCTL.md | 2 +-
dev/breeze/doc/ci/02_images.md | 2 +-
dev/breeze/pyproject.toml | 2 +-
.../commands/release_management_commands.py | 2 +-
dev/breeze/uv.lock | 239 +++-
.../react_plugin_template/package.json | 2 +-
.../react_plugin_template/pnpm-lock.yaml | 312 ++---
devel-common/pyproject.toml | 2 +-
docs/spelling_wordlist.txt | 2 +
.../airflow/providers/airbyte/operators/airbyte.py | 20 +-
.../airflow/providers/airbyte/triggers/airbyte.py | 44 +-
.../tests/unit/airbyte/operators/test_airbyte.py | 81 +-
.../tests/unit/airbyte/triggers/test_airbyte.py | 81 +-
.../apache/spark/operators/test_spark_submit.py | 18 +-
.../kubernetes/executors/kubernetes_executor.py | 8 +-
.../executors/test_kubernetes_executor.py | 31 +
providers/common/ai/docs/changelog.rst | 35 +-
providers/common/ai/docs/operators/agent.rst | 17 +-
providers/common/ai/docs/operators/llm.rst | 23 +-
.../common/ai/docs/operators/llm_file_analysis.rst | 13 +-
..._llamaindex_10k.py => example_langchain_10k.py} | 199 ++-
.../airflow/providers/common/ai/operators/agent.py | 25 +-
.../airflow/providers/common/ai/operators/llm.py | 35 +-
.../common/ai/operators/llm_file_analysis.py | 9 +
.../providers/common/ai/utils/output_type.py | 32 +-
.../tests/unit/common/ai/decorators/test_agent.py | 14 +-
.../tests/unit/common/ai/operators/test_agent.py | 39 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 47 +-
.../common/ai/operators/test_llm_file_analysis.py | 46 +-
.../tests/unit/common/ai/utils/test_output_type.py | 42 +-
.../providers/databricks/triggers/databricks.py | 7 +
.../airflow/providers/databricks/utils/retry.py | 43 +
.../unit/databricks/operators/test_databricks.py | 28 +
.../unit/databricks/sensors/test_databricks.py | 29 +
.../unit/databricks/triggers/test_databricks.py | 39 +-
.../tests/unit/databricks/utils/test_retry.py | 60 +
providers/edge3/docs/edge_executor.rst | 33 +
.../src/airflow/providers/edge3/cli/worker.py | 20 +-
.../providers/edge3/executors/edge_executor.py | 107 +-
.../src/airflow/providers/edge3/models/types.py | 46 +
.../providers/edge3/worker_api/datamodels.py | 4 +-
.../providers/edge3/worker_api/routes/jobs.py | 17 +-
.../edge3/worker_api/v2-edge-generated.yaml | 67 +-
.../edge3/tests/unit/edge3/cli/test_worker.py | 47 +
.../unit/edge3/executors/test_edge_executor.py | 135 +-
.../edge3/tests/unit/edge3/models/test_types.py | 140 ++
.../unit/edge3/worker_api/routes/test_jobs.py | 87 +-
providers/elasticsearch/pyproject.toml | 7 +
.../providers/elasticsearch/hooks/elasticsearch.py | 24 +-
.../providers/elasticsearch/utils}/__init__.py | 0
.../airflow/providers/elasticsearch/utils/sql.py | 108 ++
.../unit/elasticsearch/hooks/test_elasticsearch.py | 25 +-
.../tests/unit/elasticsearch/utils}/__init__.py | 0
.../tests/unit/elasticsearch/utils/test_sql.py | 181 +++
providers/mongo/tests/conftest.py | 14 +
.../airflow/providers/postgres/hooks/postgres.py | 50 +-
.../tests/unit/postgres/hooks/test_postgres.py | 435 ++----
providers/ssh/tests/unit/ssh/hooks/test_ssh.py | 9 +-
.../tests/unit/standard/operators/test_python.py | 2 +-
pyproject.toml | 8 -
scripts/ci/prek/check_imports_in_providers.py | 2 +-
.../check_template_context_variable_in_sync.py | 4 +-
.../ci/prek/known_provide_session_positional.txt | 1 -
scripts/ci/prek/ruff_format.py | 2 +-
shared/state/src/airflow_shared/state/__init__.py | 54 +-
shared/state/tests/state/test_state.py | 88 +-
task-sdk/docs/api.rst | 10 +
task-sdk/docs/conf.py | 3 +
task-sdk/src/airflow/sdk/api/client.py | 72 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 32 +-
task-sdk/src/airflow/sdk/bases/operator.py | 7 +
task-sdk/src/airflow/sdk/bases/resumablemixin.py | 20 +-
.../src/airflow/sdk/coordinators}/__init__.py | 5 +-
task-sdk/src/airflow/sdk/definitions/context.py | 8 +-
task-sdk/src/airflow/sdk/exceptions.py | 4 +-
.../airflow/sdk/execution_time/callback_runner.py | 2 +-
.../sdk/execution_time/callback_supervisor.py | 26 +
task-sdk/src/airflow/sdk/execution_time/comms.py | 100 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 141 +-
.../airflow/sdk/execution_time/schema/schema.json | 188 +--
.../src/airflow/sdk/execution_time/supervisor.py | 94 +-
.../src/airflow/sdk/execution_time/task_runner.py | 63 +-
task-sdk/src/airflow/sdk/serde/__init__.py | 38 +-
task-sdk/src/airflow/sdk/state.py | 2 +-
task-sdk/tests/task_sdk/api/test_client.py | 72 +-
.../tests/task_sdk/bases/test_resumablemixin.py | 6 +-
.../execution_time/test_callback_supervisor.py | 66 +
.../tests/task_sdk/execution_time/test_context.py | 324 +++--
.../task_sdk/execution_time/test_supervisor.py | 124 +-
.../task_sdk/execution_time/test_task_runner.py | 189 ++-
task-sdk/tests/task_sdk/serde/test_serde.py | 20 +
uv.lock | 724 ++++++----
188 files changed, 7216 insertions(+), 3904 deletions(-)
create mode 100644
airflow-core/docs/authoring-and-scheduling/language-sdks/index.rst
create mode 100644
airflow-core/docs/authoring-and-scheduling/language-sdks/java.rst
rename
airflow-core/src/airflow/api_fastapi/core_api/datamodels/{asset_state.py =>
asset_store.py} (83%)
rename airflow-core/src/airflow/api_fastapi/core_api/datamodels/{task_state.py
=> task_store.py} (87%)
rename
airflow-core/src/airflow/api_fastapi/core_api/routes/public/{asset_state.py =>
asset_store.py} (72%)
rename
airflow-core/src/airflow/api_fastapi/core_api/routes/public/{task_state.py =>
task_store.py} (75%)
rename
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/{asset_state.py
=> asset_store.py} (87%)
rename
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/{task_state.py =>
task_store.py} (88%)
rename
airflow-core/src/airflow/api_fastapi/execution_api/routes/{asset_state.py =>
asset_store.py} (83%)
rename
airflow-core/src/airflow/api_fastapi/execution_api/routes/{task_state.py =>
task_store.py} (85%)
rename airflow-core/src/airflow/example_dags/{example_asset_state.py =>
example_asset_store.py} (82%)
rename airflow-core/src/airflow/example_dags/{example_task_state.py =>
example_task_store.py} (81%)
rename
airflow-core/src/airflow/migrations/versions/{0112_3_3_0_add_task_state_and_asset_state_tables.py
=> 0112_3_3_0_add_task_store_and_asset_store_tables.py} (75%)
rename airflow-core/src/airflow/models/{asset_state.py => asset_store.py} (92%)
rename airflow-core/src/airflow/models/{task_state.py => task_store.py} (90%)
create mode 100644 airflow-core/src/airflow/ui/src/components/PoolBar.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dashboard/PoolSummary/PoolSummary.test.tsx
rename
airflow-core/tests/unit/api_fastapi/core_api/routes/public/{test_asset_state.py
=> test_asset_store.py} (91%)
rename
airflow-core/tests/unit/api_fastapi/core_api/routes/public/{test_task_state.py
=> test_task_store.py} (92%)
rename
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/{test_asset_state.py
=> test_asset_store.py} (93%)
rename
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/{test_task_state.py
=> test_task_store.py} (91%)
rename airflow-core/tests/unit/models/{test_asset_state.py =>
test_asset_store.py} (79%)
rename airflow-core/tests/unit/models/{test_task_state.py =>
test_task_store.py} (83%)
delete mode 100644 chart/newsfragments/67447.significant.rst
create mode 100644 chart/newsfragments/67803.significant.rst
copy
providers/common/ai/src/airflow/providers/common/ai/example_dags/{example_llamaindex_10k.py
=> example_langchain_10k.py} (74%)
create mode 100644
providers/databricks/src/airflow/providers/databricks/utils/retry.py
create mode 100644
providers/databricks/tests/unit/databricks/utils/test_retry.py
create mode 100644 providers/edge3/src/airflow/providers/edge3/models/types.py
create mode 100644 providers/edge3/tests/unit/edge3/models/test_types.py
copy {airflow-core/src/airflow/_shared =>
providers/elasticsearch/src/airflow/providers/elasticsearch/utils}/__init__.py
(100%)
create mode 100644
providers/elasticsearch/src/airflow/providers/elasticsearch/utils/sql.py
copy {airflow-core/src/airflow/_shared =>
providers/elasticsearch/tests/unit/elasticsearch/utils}/__init__.py (100%)
create mode 100644
providers/elasticsearch/tests/unit/elasticsearch/utils/test_sql.py
copy {dev/breeze/src/airflow_breeze =>
task-sdk/src/airflow/sdk/coordinators}/__init__.py (90%)
