This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/ui/core-ui-package-updates-2067516e94
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 04b8cef339a Bump the core-ui-package-updates group across 1 directory
with 46 updates
add 17ee4c0d27c Fix translation for favourites (#53023)
add 7ea7fcdda67 Make dag_version_id in TI non-nullable (#50825)
add a596e48b85a Remove unused Task Callback execution logic from Scheduler
(#53031)
add fb29426ae23 Remove unused ``PipeCallbackSink`` (#53037)
add 50b4c63270e Remove `set_current_context` from
`airflow.models.taskinstance` (#53036)
add 65aa40899ef Add run_id_pattern search for Dag Run API. (#52437)
add fc116c39ffb AIP-68 - Add iframe plugins as tabs on dag pages (#52795)
add 39624dc5e21 AIP-86 - Calculate and store the dagrun Deadline (#51638)
add 5fbbf641b32 Add endpoint to watch dag run until finish (#51920)
add 9f04812b516 Update `provider-version-compat` to be portable across CI
and systems (#53072)
add 3eaf4e90b69 Invalidate grid runs and summaries and TI/Runs actions
(#53081)
add a5211f2efd5 Run Task failure callbacks on DAG Processor when task is
externally killed (#53058)
add 7a45a927201 Make amazon provider compatible with mypy 1.16.1 (#53088)
add 07b5b7f72c2 Bump packaging>=25.0 (#53073)
add d8a3ad24df5 Refactor serve_logs with FastAPI (#52581)
add 0a047bd8af2 AIP-68 Add loading validation to React App and External
Views (#52972)
add 8b04c3882b0 Fix no_status and duration for grid summaries (#53087)
add b5ef6ae5d25 Deprecate old DV360 operator and modify system test
(#53027)
add f46c9b3676f Some minor corrections to PMC instructions for provider
release (#53068)
add 5c2a2ecd0d7 Unify connection not found exceptions between AF2 and AF3
(#52968)
add 89a329cce1c Move` XCOM_RETURN_KEY` constant into `BaseXCom` (#53076)
add 9182725a389 Clean up in google provider (#53090)
add ac780ce8032 Bump the core-ui-package-updates group across 1 directory
with 46 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 (04b8cef339a)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/core-ui-package-updates-2067516e94
(ac780ce8032)
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 +-
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/img/airflow_erd.svg | 3 +-
airflow-core/docs/migrations-ref.rst | 4 +-
airflow-core/pyproject.toml | 6 +-
airflow-core/src/airflow/api_fastapi/app.py | 2 +
.../src/airflow/api_fastapi/core_api/app.py | 7 +
.../core_api/datamodels/task_instances.py | 2 +-
.../api_fastapi/core_api/datamodels/ui/common.py | 8 +-
.../api_fastapi/core_api/datamodels/ui/grid.py | 2 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 2 -
.../core_api/openapi/v2-rest-api-generated.yaml | 104 ++++++-
.../api_fastapi/core_api/routes/public/dag_run.py | 60 ++++
.../airflow/api_fastapi/core_api/routes/ui/grid.py | 1 -
.../core_api/services/public/dag_run.py | 85 ++++++
.../api_fastapi/core_api/services/ui/grid.py | 2 +-
.../execution_api/datamodels/taskinstance.py | 5 +-
.../api_fastapi/execution_api/versions/__init__.py | 2 +
.../execution_api/versions/v2025_08_10.py | 18 +-
.../src/airflow/callbacks/callback_requests.py | 2 +
.../src/airflow/callbacks/pipe_callback_sink.py | 51 ----
.../src/airflow/cli/commands/task_command.py | 9 +-
.../src/airflow/dag_processing/processor.py | 71 ++++-
airflow-core/src/airflow/executors/workloads.py | 2 +-
.../src/airflow/jobs/scheduler_job_runner.py | 18 +-
...6_3_1_0_make_dag_version_id_non_nullable_in_.py | 81 +++++
airflow-core/src/airflow/models/connection.py | 2 +-
airflow-core/src/airflow/models/dag.py | 30 +-
airflow-core/src/airflow/models/dagrun.py | 22 +-
airflow-core/src/airflow/models/deadline.py | 31 +-
airflow-core/src/airflow/models/taskinstance.py | 100 +------
airflow-core/src/airflow/plugins_manager.py | 38 ++-
airflow-core/src/airflow/settings.py | 47 +--
.../src/airflow/ui/openapi-gen/queries/common.ts | 25 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 42 ++-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 42 ++-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 42 ++-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 42 ++-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 18 +-
.../ui/openapi-gen/requests/services.gen.ts | 73 ++++-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 48 ++-
airflow-core/src/airflow/ui/package.json | 6 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 134 ++++-----
.../airflow/ui/public/i18n/locales/en/dags.json | 3 +-
.../airflow/ui/public/i18n/locales/pl/dags.json | 4 +-
.../src/airflow/ui/src/constants/searchParams.ts | 1 +
.../src/airflow/ui/src/hooks/usePluginTabs.tsx | 64 ++++
.../src/airflow/ui/src/hooks/useSelectedVersion.ts | 2 +-
.../ui/src/layouts/Details/DetailsLayout.tsx | 2 +-
airflow-core/src/airflow/ui/src/pages/Dag/Dag.tsx | 5 +
airflow-core/src/airflow/ui/src/pages/DagRuns.tsx | 45 ++-
airflow-core/src/airflow/ui/src/pages/Iframe.tsx | 37 ++-
airflow-core/src/airflow/ui/src/pages/Run/Run.tsx | 5 +
.../src/airflow/ui/src/pages/Task/Task.tsx | 5 +
.../ui/src/pages/TaskInstance/TaskInstance.tsx | 5 +
.../src/airflow/ui/src/queries/useClearRun.ts | 4 +
.../ui/src/queries/useClearTaskInstances.ts | 4 +
.../src/airflow/ui/src/queries/usePatchDagRun.ts | 4 +
.../airflow/ui/src/queries/usePatchTaskInstance.ts | 4 +
airflow-core/src/airflow/ui/src/router.tsx | 25 +-
airflow-core/src/airflow/utils/db.py | 2 +-
.../{listeners => utils/serve_logs}/__init__.py | 6 +-
airflow-core/src/airflow/utils/serve_logs/core.py | 65 ++++
.../{serve_logs.py => serve_logs/log_server.py} | 186 +++++-------
.../tests/unit/always/test_project_structure.py | 10 +
.../core_api/routes/public/test_dag_run.py | 75 ++++-
.../core_api/routes/public/test_task_instances.py | 121 +++++---
.../core_api/routes/public/test_xcom.py | 16 +-
.../api_fastapi/core_api/routes/ui/test_grid.py | 112 ++++++-
.../tests/unit/callbacks/test_callback_requests.py | 31 +-
.../tests/unit/cli/commands/test_task_command.py | 10 +-
.../tests/unit/dag_processing/test_processor.py | 327 ++++++++++++++++++---
.../tests/unit/executors/test_base_executor.py | 2 +-
.../tests/unit/executors/test_local_executor.py | 1 +
airflow-core/tests/unit/jobs/test_scheduler_job.py | 158 +++++-----
airflow-core/tests/unit/jobs/test_triggerer_job.py | 15 +-
.../tests/unit/models/test_baseoperator.py | 11 +-
airflow-core/tests/unit/models/test_cleartasks.py | 5 +-
airflow-core/tests/unit/models/test_dag.py | 86 +++++-
airflow-core/tests/unit/models/test_dagrun.py | 51 ++--
airflow-core/tests/unit/models/test_deadline.py | 82 +++++-
.../tests/unit/models/test_mappedoperator.py | 33 ++-
airflow-core/tests/unit/models/test_pool.py | 15 +-
.../tests/unit/models/test_taskinstance.py | 119 ++------
airflow-core/tests/unit/models/test_taskmap.py | 6 +-
airflow-core/tests/unit/models/test_trigger.py | 8 +-
airflow-core/tests/unit/models/test_xcom.py | 17 +-
.../tests/unit/plugins/test_plugins_manager.py | 42 +++
.../unit/serialization/test_serialized_objects.py | 3 +
.../deps/test_dag_ti_slots_available_dep.py | 5 +-
.../unit/ti_deps/deps/test_dag_unpaused_dep.py | 5 +-
.../ti_deps/deps/test_not_in_retry_period_dep.py | 3 +-
.../unit/ti_deps/deps/test_prev_dagrun_dep.py | 3 +
.../unit/ti_deps/deps/test_trigger_rule_dep.py | 10 +-
airflow-core/tests/unit/utils/test_db_cleanup.py | 15 +-
airflow-core/tests/unit/utils/test_log_handlers.py | 13 +-
airflow-core/tests/unit/utils/test_serve_logs.py | 35 +--
airflow-core/tests/unit/utils/test_sqlalchemy.py | 4 +-
airflow-core/tests/unit/utils/test_state.py | 3 +
.../test_task_handler_with_custom_formatter.py | 4 +-
.../src/airflowctl/api/datamodels/generated.py | 2 +-
dev/README_RELEASE_PROVIDERS.md | 10 +-
dev/breeze/pyproject.toml | 2 +-
dev/pyproject.toml | 2 +-
devel-common/src/tests_common/pytest_plugin.py | 1 +
.../src/tests_common/test_utils/mock_context.py | 20 +-
.../src/tests_common/test_utils/system_tests.py | 13 +
docs/spelling_wordlist.txt | 1 +
.../test_kubernetes_pod_operator.py | 5 +-
.../providers/amazon/aws/hooks/redshift_cluster.py | 8 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 55 ++--
.../unit/amazon/aws/log/test_s3_task_handler.py | 134 +++++----
.../tests/unit/amazon/aws/operators/test_athena.py | 9 +-
.../unit/amazon/aws/operators/test_datasync.py | 41 ++-
.../tests/unit/amazon/aws/operators/test_dms.py | 16 +-
.../amazon/aws/operators/test_emr_add_steps.py | 17 +-
.../aws/operators/test_emr_create_job_flow.py | 17 +-
.../tests/unit/amazon/aws/operators/test_s3.py | 12 +-
.../amazon/aws/operators/test_sagemaker_base.py | 9 +-
.../tests/unit/amazon/aws/sensors/test_s3.py | 17 +-
.../tests/unit/amazon/aws/transfers/test_base.py | 10 +-
.../amazon/aws/transfers/test_dynamodb_to_s3.py | 10 +-
.../unit/amazon/aws/transfers/test_mongo_to_s3.py | 9 +-
.../unit/amazon/aws/utils/eks_test_constants.py | 4 +-
.../unit/apache/kylin/operators/test_kylin_cube.py | 10 +-
.../apache/spark/operators/test_spark_submit.py | 10 +-
.../integration/celery/test_celery_executor.py | 11 +-
.../unit/celery/executors/test_celery_executor.py | 45 ++-
.../cncf/kubernetes/cli/kubernetes_command.py | 7 +-
.../kubernetes/log_handlers/test_log_handlers.py | 8 +-
.../unit/cncf/kubernetes/operators/test_job.py | 11 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 14 +-
.../kubernetes/operators/test_spark_kubernetes.py | 7 +-
.../tests/unit/common/sql/operators/test_sql.py | 4 +
.../tests/unit/docker/decorators/test_docker.py | 5 +-
.../tests/unit/docker/operators/test_docker.py | 3 +-
.../edge3/tests/unit/edge3/cli/test_worker.py | 1 +
.../unit/edge3/executors/test_edge_executor.py | 1 +
.../operators/marketing_platform/display_video.rst | 72 ++---
.../marketing_platform/hooks/display_video.py | 50 +++-
.../marketing_platform/operators/display_video.py | 79 ++++-
.../marketing_platform/sensors/display_video.py | 11 +-
providers/google/tests/deprecations_ignore.yml | 17 ++
.../marketing_platform/example_display_video.py | 248 ++++++++--------
.../google/cloud/hooks/test_bigquery_system.py | 84 ------
.../cloud/hooks/test_secret_manager_system.py | 45 ---
.../cloud/log/test_gcs_task_handler_system.py | 105 -------
.../log/test_stackdriver_task_handler_system.py | 110 -------
.../google/cloud/operators/test_dataprep_system.py | 59 ----
.../cloud/operators/test_datastore_system.py | 51 ----
.../cloud/secrets/test_secret_manager_system.py | 72 -----
.../tests/unit/google/cloud/utils/airflow_util.py | 7 +-
.../marketing_platform/hooks/test_display_video.py | 76 ++---
.../operators/test_display_video.py | 219 +++++++-------
.../sensors/test_display_video.py | 9 +-
.../microsoft/azure/operators/test_data_factory.py | 8 +-
.../unit/microsoft/azure/sensors/test_wasb.py | 18 +-
.../tests/unit/openlineage/plugins/test_adapter.py | 46 ++-
.../unit/openlineage/plugins/test_listener.py | 17 +-
.../tests/unit/openlineage/utils/test_utils.py | 190 ++++++++----
.../unit/redis/log/test_redis_task_handler.py | 11 +-
.../unit/snowflake/operators/test_snowflake.py | 10 +-
providers/ssh/tests/unit/ssh/operators/test_ssh.py | 15 +-
.../tests/unit/standard/decorators/test_python.py | 10 +-
.../tests/unit/standard/operators/test_python.py | 5 +-
.../standard/sensors/test_external_task_sensor.py | 73 ++++-
.../tests/unit/standard/sensors/test_time_delta.py | 91 +++---
.../tests/unit/standard/sensors/test_weekday.py | 14 +-
.../tests/unit/standard/utils/test_skipmixin.py | 91 +++++-
.../yandex/tests/unit/yandex/links/test_yq.py | 10 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 5 +-
task-sdk/src/airflow/sdk/bases/xcom.py | 2 +
task-sdk/src/airflow/sdk/definitions/connection.py | 10 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 1 +
task-sdk/src/airflow/sdk/definitions/deadline.py | 31 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 4 +-
task-sdk/src/airflow/sdk/definitions/xcom_arg.py | 16 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 2 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 4 +-
.../src/airflow/sdk/execution_time/task_runner.py | 6 +-
task-sdk/src/airflow/sdk/types.py | 4 +-
task-sdk/tests/task_sdk/bases/test_hook.py | 5 +-
.../tests/task_sdk/definitions/test_connections.py | 12 +-
.../tests/task_sdk/definitions/test_deadline.py | 50 +---
.../task_sdk/definitions/test_mappedoperator.py | 13 +-
.../tests/task_sdk/definitions/test_xcom_arg.py | 21 +-
.../tests/task_sdk/execution_time/test_comms.py | 1 +
.../tests/task_sdk/execution_time/test_context.py | 9 +-
.../task_sdk/execution_time/test_lazy_sequence.py | 16 +-
.../task_sdk/execution_time/test_supervisor.py | 30 +-
.../task_sdk/execution_time/test_task_runner.py | 27 +-
task-sdk/tests/task_sdk/log/test_log.py | 11 +-
192 files changed, 3870 insertions(+), 2121 deletions(-)
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/services/public/dag_run.py
copy providers/cloudant/src/airflow/providers/cloudant/cloudant_fake.py =>
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_08_10.py (69%)
delete mode 100644 airflow-core/src/airflow/callbacks/pipe_callback_sink.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0076_3_1_0_make_dag_version_id_non_nullable_in_.py
create mode 100644 airflow-core/src/airflow/ui/src/hooks/usePluginTabs.tsx
copy airflow-core/src/airflow/{listeners => utils/serve_logs}/__init__.py (84%)
create mode 100644 airflow-core/src/airflow/utils/serve_logs/core.py
rename airflow-core/src/airflow/utils/{serve_logs.py =>
serve_logs/log_server.py} (60%)
delete mode 100644
providers/google/tests/unit/google/cloud/hooks/test_bigquery_system.py
delete mode 100644
providers/google/tests/unit/google/cloud/hooks/test_secret_manager_system.py
delete mode 100644
providers/google/tests/unit/google/cloud/log/test_gcs_task_handler_system.py
delete mode 100644
providers/google/tests/unit/google/cloud/log/test_stackdriver_task_handler_system.py
delete mode 100644
providers/google/tests/unit/google/cloud/operators/test_dataprep_system.py
delete mode 100644
providers/google/tests/unit/google/cloud/operators/test_datastore_system.py
delete mode 100644
providers/google/tests/unit/google/cloud/secrets/test_secret_manager_system.py
