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/api_fastapi/auth/managers/simple/ui/core-ui-package-updates-04f447e0d3
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit a2aa980370b Bump the core-ui-package-updates group across 1 directory
with 5 updates
add dc0e38a8bd8 Make google provider compatible with mypy 1.16.1 (#53148)
add b860dd17b21 Update INTHEWILD.md with Acciona Energia France (#53132)
add 155124dde2b fix: Improve logging and timeouts in OL helpers (#53139)
add 3ad42398f08 Bugfix/close german translation gaps 2025 07 07 (#52995)
add 7ab13431b20 Remove unused Exceptions (#53155)
add a8e7b6c583a Run mypy for all types when devel-common toml changes
(#53156)
add 35a6b2c0f29 Fix GCSToBigQueryOperator: avoid pushing non-serializable
task_instance to XCom (#53094)
add 848ff9eecf4 Use standard library ``typing`` imports for Python 3.10+
(#53158)
add fc993d3d648 feat: Add toggle to hide/show log timestamps in UI (#52996)
add 015673658c1 Create connection with API instead of directly through
Session (#53161)
add d3dbc28effa Add Human-in-the-loop logic to core Airflow and implement
`HITLOperator`, `ApprovalOperator`, `HITLEntryOperator` in standard provider
(#52868)
add 16ff7dcb3b8 Move ``SetupTeardownContext`` to Task SDK (#53160)
add 98c1da8cc11 Removing `airflow.utils.xcom` references in airflow-core
(#53144)
add 8b3ba0090e6 Replace usages of XCOM_RETURN_KEY in providers to not be
from utils (#53170)
add 8bee736db80 Remove some remnants of airflow.utils.xcom usage in core
(#53169)
add a480f77e747 Make task-sdk compatible with mypy 1.16.1 (#53047)
add a5c5c3fc572 Import XCOM_RETURN_KEY in providers from task SDK (#53180)
add 47bbe553557 Move --no-binary flag to uv command line from
pyproject.toml (#53179)
add b9620bf4b77 Fix reading huge (XCom) resposne in TaskSDK task process
(#53186)
add 5aec2d5ea87 Install python from source again (#53150)
add 8d18c6938f0 Add type casting for mypy to understand expand_input types
(#53191)
add bc79040f19f Adjust ray operators in google provider. Add ray package
as a dependency. (#53182)
add ac6e953603b Bump the core-ui-package-updates group across 1 directory
with 5 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 (a2aa980370b)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/core-ui-package-updates-04f447e0d3
(ac6e953603b)
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:
.dockerignore | 1 +
.github/workflows/additional-ci-image-checks.yml | 2 +-
.github/workflows/basic-tests.yml | 6 +
.pre-commit-config.yaml | 2 +-
Dockerfile | 21 +-
Dockerfile.ci | 98 ++-
INTHEWILD.md | 1 +
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/img/airflow_erd.svg | 812 +++++++++++----------
airflow-core/docs/migrations-ref.rst | 4 +-
.../api_fastapi/auth/managers/base_auth_manager.py | 3 +-
.../api_fastapi/core_api/datamodels/hitl.py | 77 ++
.../core_api/openapi/v2-rest-api-generated.yaml | 421 +++++++++++
.../api_fastapi/core_api/routes/public/__init__.py | 2 +
.../api_fastapi/core_api/routes/public/hitl.py | 274 +++++++
.../api_fastapi/execution_api/datamodels/hitl.py | 72 ++
.../api_fastapi/execution_api/routes/__init__.py | 2 +
.../api_fastapi/execution_api/routes/hitl.py | 108 +++
.../execution_api/routes/task_instances.py | 9 +-
airflow-core/src/airflow/cli/simple_table.py | 2 +-
airflow-core/src/airflow/exceptions.py | 47 --
.../src/airflow/jobs/triggerer_job_runner.py | 35 +-
.../0077_3_1_0_add_human_in_the_loop_response.py | 78 ++
airflow-core/src/airflow/models/__init__.py | 1 +
airflow-core/src/airflow/models/dag.py | 3 +-
airflow-core/src/airflow/models/dagrun.py | 2 +-
airflow-core/src/airflow/models/expandinput.py | 3 +-
airflow-core/src/airflow/models/hitl.py | 69 ++
airflow-core/src/airflow/models/taskinstance.py | 5 +-
airflow-core/src/airflow/models/taskmixin.py | 2 +-
airflow-core/src/airflow/models/xcom.py | 9 +-
airflow-core/src/airflow/models/xcom_arg.py | 2 +-
airflow-core/src/airflow/providers_manager.py | 3 +-
airflow-core/src/airflow/typing_compat.py | 13 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 25 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 41 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 41 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 90 ++-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 41 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 177 +++++
.../ui/openapi-gen/requests/services.gen.ts | 146 +++-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 220 ++++++
.../airflow/ui/public/i18n/locales/de/README.md | 2 +-
.../ui/public/i18n/locales/de/components.json | 4 +-
.../airflow/ui/public/i18n/locales/de/dags.json | 12 +-
.../ui/public/i18n/locales/de/dashboard.json | 6 +
.../airflow/ui/public/i18n/locales/en/common.json | 12 +
.../src/airflow/ui/public/i18n/locales/en/dag.json | 1 +
.../ui/src/components/renderStructuredLog.tsx | 24 +-
.../ui/src/pages/TaskInstance/Logs/Logs.test.tsx | 18 +-
.../ui/src/pages/TaskInstance/Logs/Logs.tsx | 23 +-
.../src/pages/TaskInstance/Logs/TaskLogHeader.tsx | 91 ++-
.../src/airflow/ui/src/queries/useLogs.tsx | 12 +
airflow-core/src/airflow/utils/__init__.py | 11 +
airflow-core/src/airflow/utils/db.py | 2 +-
.../src/airflow/utils/log/file_task_handler.py | 3 +-
airflow-core/src/airflow/utils/log/log_reader.py | 3 +-
.../utils/providers_configuration_loader.py | 4 +-
airflow-core/src/airflow/utils/session.py | 3 +-
airflow-core/src/airflow/utils/task_group.py | 2 +-
airflow-core/src/airflow/utils/types.py | 2 +-
airflow-core/src/airflow/utils/xcom.py | 1 +
.../core_api/routes/public/test_hitl.py | 391 ++++++++++
.../execution_api/versions/head/test_hitl.py | 140 ++++
.../tests/unit/models/test_taskinstance.py | 3 +-
airflow-core/tests/unit/models/test_trigger.py | 3 +-
airflow-core/tests/unit/models/test_xcom.py | 5 +-
.../unit/serialization/test_dag_serialization.py | 3 +-
.../ti_deps/deps/test_mapped_task_upstream_dep.py | 2 +-
.../src/airflowctl/api/datamodels/generated.py | 48 ++
dev/breeze/src/airflow_breeze/global_constants.py | 10 +
.../src/airflow_breeze/params/build_ci_params.py | 4 +
.../src/airflow_breeze/utils/selective_checks.py | 16 +
dev/breeze/tests/test_selective_checks.py | 10 +
.../src/tests_common/test_utils/version_compat.py | 17 +
.../src/airflow/providers/amazon/aws/hooks/ec2.py | 3 +-
.../airflow/providers/amazon/aws/utils/suppress.py | 4 +-
.../tests/system/amazon/aws/example_http_to_s3.py | 23 +-
.../celery/executors/celery_executor_utils.py | 3 +-
.../providers/cncf/kubernetes/operators/pod.py | 3 +-
.../providers/cncf/kubernetes/version_compat.py | 3 +
.../unit/cncf/kubernetes/operators/test_pod.py | 3 +-
.../io/tests/unit/common/io/xcom/test_backend.py | 3 +-
.../providers/databricks/utils/openlineage.py | 31 +-
.../unit/databricks/utils/test_openlineage.py | 22 +-
.../google/docs/operators/cloud/vertex_ai.rst | 4 +
providers/google/pyproject.toml | 7 +-
.../providers/google/cloud/hooks/bigquery.py | 2 +-
.../providers/google/cloud/hooks/cloud_sql.py | 4 +
.../providers/google/cloud/hooks/datafusion.py | 2 +-
.../airflow/providers/google/cloud/hooks/gcs.py | 3 +-
.../google/cloud/links/kubernetes_engine.py | 3 +
.../providers/google/cloud/operators/bigquery.py | 6 +-
.../google/cloud/operators/vertex_ai/ray.py | 12 +-
.../providers/google/cloud/sensors/datafusion.py | 4 +-
.../google/cloud/transfers/gcs_to_bigquery.py | 1 -
.../providers/google/cloud/triggers/bigquery.py | 6 +-
.../cloud/vertex_ai/example_vertex_ai_ray.py | 8 +-
.../providers/microsoft/azure/operators/msgraph.py | 3 +-
.../providers/microsoft/azure/version_compat.py | 16 +-
.../providers/snowflake/utils/openlineage.py | 14 +-
.../tests/unit/snowflake/utils/test_openlineage.py | 22 +-
providers/standard/provider.yaml | 2 +
.../src/airflow/providers/standard/exceptions.py | 8 +
.../providers/standard/get_provider_info.py | 2 +
.../airflow/providers/standard/models}/__init__.py | 0
.../airflow/providers/standard/operators/hitl.py | 232 ++++++
.../airflow/providers/standard/triggers/hitl.py | 132 ++++
.../tests/unit/standard/decorators/test_python.py | 3 +-
.../tests/unit/standard/operators/test_hitl.py | 269 +++++++
.../tests/unit/standard/triggers/test_hitl.py | 161 ++++
pyproject.toml | 3 -
.../pre_commit/update_installers_and_pre_commit.py | 68 ++
scripts/docker/common.sh | 9 +-
scripts/docker/entrypoint_ci.sh | 12 +-
.../docker/install_airflow_when_building_images.sh | 12 +-
...pendencies.sh => install_os_dependencies_ci.sh} | 38 +-
task-sdk/src/airflow/sdk/api/client.py | 76 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 54 ++
task-sdk/src/airflow/sdk/bases/decorator.py | 3 +-
task-sdk/src/airflow/sdk/bases/operator.py | 2 +-
.../sdk/definitions/_internal/abstractoperator.py | 2 +-
.../sdk/definitions/_internal/expandinput.py | 8 +-
.../sdk/definitions/_internal}/setup_teardown.py | 4 +-
.../src/airflow/sdk/definitions/asset/__init__.py | 4 +-
.../sdk/definitions/decorators/setup_teardown.py | 16 +-
.../sdk/definitions/decorators/task_group.py | 3 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 3 +-
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 8 +-
task-sdk/src/airflow/sdk/definitions/xcom_arg.py | 2 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 56 +-
task-sdk/src/airflow/sdk/execution_time/hitl.py | 83 +++
.../airflow/sdk/execution_time/secrets_masker.py | 10 +-
.../src/airflow/sdk/execution_time/supervisor.py | 14 +-
task-sdk/tests/task_sdk/api/test_client.py | 106 +++
.../tests/task_sdk/execution_time/test_comms.py | 30 +
.../tests/task_sdk/execution_time/test_hitl.py | 95 +++
.../task_sdk/execution_time/test_supervisor.py | 45 ++
138 files changed, 4927 insertions(+), 723 deletions(-)
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/datamodels/hitl.py
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/routes/public/hitl.py
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/hitl.py
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/routes/hitl.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0077_3_1_0_add_human_in_the_loop_response.py
create mode 100644 airflow-core/src/airflow/models/hitl.py
create mode 100644
airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_hitl.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_hitl.py
copy {airflow-core/src/airflow/api =>
providers/standard/src/airflow/providers/standard/models}/__init__.py (100%)
create mode 100644
providers/standard/src/airflow/providers/standard/operators/hitl.py
create mode 100644
providers/standard/src/airflow/providers/standard/triggers/hitl.py
create mode 100644
providers/standard/tests/unit/standard/operators/test_hitl.py
create mode 100644 providers/standard/tests/unit/standard/triggers/test_hitl.py
copy scripts/docker/{install_os_dependencies.sh =>
install_os_dependencies_ci.sh} (80%)
rename {airflow-core/src/airflow/utils =>
task-sdk/src/airflow/sdk/definitions/_internal}/setup_teardown.py (99%)
create mode 100644 task-sdk/src/airflow/sdk/execution_time/hitl.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_hitl.py
