This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/providers/fab/src/airflow/providers/fab/www/fab-ui-package-updates-e464ea7670
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 4a848accb55 Bump mini-css-extract-plugin
add 5b7de62a1f5 Add MwaaTaskSensor to Amazon Provider Package (#51719)
add cbec199d230 Close German translation gaps for full UI translation
2025-07-29 (#53897)
add fa4a6ed89be Do not include GitHub bots in release test requests
(#54137)
add 85de1fe9b80 Add FAQ entry about testing connections and "Canary" Dag
(#54110)
add df00a508e68 AIP-86 - Scheduler loop checks for any missed Deadlines
and hands them off to be executed (#53903)
add 72eeba799a1 Add `test_connection` method to `WinRMHook` (#47477)
add a46a8bfad5e Add missing PL translations - 01.08.2025 (#54028)
add 634b79729e7 Fix serialization order of ops (#54139)
add d7939a58446 AIP-86 - Implement Deadline Callback definition (#53951)
add e1d155c3d76 AIP-68 Fix multiple react app plugins (#54144)
add 9b1c16c2c84 feat(htil): add `notifiers` to HITLOperator (#54128)
add a8e169658ac i18n(tw): Add human in the loop translations (#54147)
add 5faa2414098 Move dag cycle checking logic inside the task SDK dag
class (#53934)
add 46410657253 AIP-82: Add RedisPubSubMessageQueueProvider (#53556)
add 3df18a07a1c Fix type error with TIH when reading served log (#54114)
add 749317d3652 Silence mypy warnings for microsoft azure WasbAsyncHook
(#54168)
add 73a2d811a63 Fix location and timeout for Workflows and Dataproc
Metastore system tests (#54167)
add 9cc07176418 Set minimum version for common.messaging to 1.0.3 (#54160)
add 9d48f7c88a4 Add backward compatibility layer for dag_cycle_tester
(#54169)
add afb34c00909 feat(cli): add YAML/ENV support to `airflow variables
import` (#53726)
add f91d192569d Restore `execute_complete` functionality `TimeSensor` when
`deferrable=True` (#53669)
add 8bbc121a6b2 Restrict typing-paramiko to < 4 as we do with paramiko
(#54173)
add ec754f8480c Replace airflow.utils.helpers imports with better
alternatives in task SDK (#53929)
add 6253ad659e5 Add Private Service Connect interface support to VertexAI
operators (#54170)
add 6ecc0e9a7e3 Bump min task sdk version in core to 1.0.4 (#54171)
add 60ad539cf7e Add system test for Lambda executor Dead Letter Queue
(DLQ) processing (#54042)
add b22b1a64924 Handle task timeouts within task SDK (#54089)
add fa731037501 Do not run export operations in `example_dynamodb_to_s3`
(#54158)
add 0c2ed9e104a Navigate Grid view via keyboard (#51784)
add 4164199c718 Bump mini-css-extract-plugin
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 (4a848accb55)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/providers/fab/src/airflow/providers/fab/www/fab-ui-package-updates-e464ea7670
(4164199c718)
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 | 1 +
airflow-core/docs/faq.rst | 35 +++
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/img/airflow_erd.svg | 264 ++++++++++----------
airflow-core/docs/migrations-ref.rst | 4 +-
.../src/airflow/cli/commands/variable_command.py | 22 +-
airflow-core/src/airflow/exceptions.py | 30 ++-
.../src/airflow/jobs/scheduler_job_runner.py | 17 +-
... 0081_3_1_0_modify_deadline_callback_schema.py} | 33 +--
airflow-core/src/airflow/models/dag.py | 12 -
airflow-core/src/airflow/models/dagbag.py | 3 +-
airflow-core/src/airflow/models/deadline.py | 63 +++--
airflow-core/src/airflow/models/mappedoperator.py | 19 +-
.../src/airflow/secrets/local_filesystem.py | 29 ++-
airflow-core/src/airflow/serialization/serde.py | 14 +-
.../src/airflow/serialization/serializers/numpy.py | 7 +-
airflow-core/src/airflow/triggers/deadline.py | 6 +-
.../airflow/ui/public/i18n/locales/de/common.json | 1 +
.../airflow/ui/public/i18n/locales/de/dags.json | 1 +
.../src/airflow/ui/public/i18n/locales/en/dag.json | 5 +
.../airflow/ui/public/i18n/locales/pl/admin.json | 1 +
.../airflow/ui/public/i18n/locales/pl/common.json | 2 +
.../src/airflow/ui/public/i18n/locales/pl/dag.json | 1 +
.../airflow/ui/public/i18n/locales/pl/dags.json | 3 +-
.../ui/public/i18n/locales/pl/dashboard.json | 1 +
.../airflow/ui/public/i18n/locales/pl/hitl.json | 25 ++
.../ui/public/i18n/locales/zh-TW/common.json | 1 +
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 6 +
.../airflow/ui/public/i18n/locales/zh-TW/dags.json | 3 +-
.../ui/public/i18n/locales/zh-TW/dashboard.json | 1 +
.../airflow/ui/public/i18n/locales/zh-TW/hitl.json | 23 ++
.../ui/ActionBar => hooks/navigation}/index.ts | 18 +-
.../src/airflow/ui/src/hooks/navigation/types.ts | 48 ++++
.../src/hooks/navigation/useKeyboardNavigation.ts | 77 ++++++
.../ui/src/hooks/navigation/useNavigation.ts | 214 +++++++++++++++++
.../airflow/ui/src/layouts/Details/Grid/Bar.tsx | 6 +-
.../airflow/ui/src/layouts/Details/Grid/Grid.tsx | 82 ++++++-
.../airflow/ui/src/layouts/Details/Grid/GridTI.tsx | 4 +-
.../layouts/Details/Grid/TaskInstancesColumn.tsx | 4 +-
.../ui/src/layouts/Details/Grid/TaskNames.tsx | 6 +-
.../src/airflow/ui/src/pages/ReactPlugin.tsx | 36 ++-
airflow-core/src/airflow/utils/dag_cycle_tester.py | 51 ++--
airflow-core/src/airflow/utils/db.py | 2 +-
airflow-core/src/airflow/utils/helpers.py | 47 ++--
.../src/airflow/utils/log/file_task_handler.py | 4 +-
airflow-core/src/airflow/utils/module_loading.py | 1 +
.../unit/always/test_secrets_local_filesystem.py | 51 ++--
.../unit/cli/commands/test_variable_command.py | 7 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 42 ++++
airflow-core/tests/unit/models/test_dag.py | 9 +-
airflow-core/tests/unit/models/test_dagrun.py | 6 +-
airflow-core/tests/unit/models/test_deadline.py | 45 ++--
.../serialization/serializers/test_serializers.py | 19 +-
.../unit/serialization/test_serialized_objects.py | 23 +-
airflow-core/tests/unit/utils/test_dag_cycle.py | 17 +-
airflow-core/tests/unit/utils/test_log_handlers.py | 12 +
.../commands/release_management_commands.py | 2 +-
devel-common/pyproject.toml | 3 +-
devel-common/src/docs/utils/conf_constants.py | 2 +-
docs/spelling_wordlist.txt | 3 +
providers/amazon/docs/operators/mwaa.rst | 16 ++
providers/amazon/pyproject.toml | 2 +-
.../airflow/providers/amazon/aws/sensors/mwaa.py | 153 +++++++++++-
.../airflow/providers/amazon/aws/triggers/base.py | 2 +-
.../airflow/providers/amazon/aws/triggers/mwaa.py | 94 +++++++-
.../airflow/providers/amazon/aws/waiters/mwaa.json | 5 +
.../system/amazon/aws/example_dynamodb_to_s3.py | 41 ++--
.../amazon/tests/system/amazon/aws/example_mwaa.py | 43 +++-
.../amazon/aws/tests/test_lambda_executor_dlq.py | 114 +++++++++
.../tests/unit/amazon/aws/sensors/test_mwaa.py | 83 +++++--
.../tests/unit/amazon/aws/triggers/test_mwaa.py | 89 ++++++-
providers/apache/kafka/pyproject.toml | 4 +-
.../google/docs/operators/cloud/vertex_ai.rst | 13 +
providers/google/pyproject.toml | 2 +-
.../google/cloud/hooks/vertex_ai/custom_job.py | 28 ++-
.../google/cloud/operators/vertex_ai/custom_job.py | 15 ++
.../example_dataproc_metastore.py | 2 +-
.../example_dataproc_metastore_backup.py | 4 +-
.../google/cloud/workflows/example_workflows.py | 2 +-
.../unit/google/cloud/operators/test_vertex_ai.py | 6 +
.../providers/microsoft/azure/hooks/wasb.py | 13 +-
.../providers/microsoft/winrm/hooks/winrm.py | 9 +
.../attempt=1.log | 0
providers/redis/docs/index.rst | 1 +
providers/redis/docs/message-queues.rst | 72 ++++++
providers/redis/provider.yaml | 3 +
providers/redis/pyproject.toml | 8 +
.../airflow/providers/redis/get_provider_info.py | 1 +
.../airflow/providers/redis/queues}/__init__.py | 0
.../src/airflow/providers/redis/queues/redis.py} | 51 ++--
.../tests/integration/redis/queues}/__init__.py | 0
.../queues/test_redis_pubsub_message_queue.py | 60 +++++
.../redis/example_dag_message_queue_trigger.py} | 10 +-
.../redis/tests/unit/redis/queues}/__init__.py | 0
.../tests/unit/redis/queues/test_redis.py} | 47 ++--
.../standard/example_dags/example_hitl_operator.py | 84 ++++++-
.../airflow/providers/standard/operators/hitl.py | 12 +-
.../src/airflow/providers/standard/sensors/time.py | 6 +-
.../tests/unit/standard/operators/test_hitl.py | 6 +
.../tests/unit/standard/sensors/test_time.py | 14 ++
pyproject.toml | 6 +-
.../ci/pre_commit/update_airflow_pyproject_toml.py | 2 +-
task-sdk/src/airflow/sdk/bases/decorator.py | 7 +-
.../airflow/sdk/definitions/_internal/templater.py | 2 +-
task-sdk/src/airflow/sdk/definitions/context.py | 47 +++-
task-sdk/src/airflow/sdk/definitions/dag.py | 47 +++-
task-sdk/src/airflow/sdk/definitions/deadline.py | 164 ++++++++++---
.../sdk/definitions/decorators/task_group.py | 3 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 29 ++-
task-sdk/src/airflow/sdk/exceptions.py | 6 +
.../src/airflow/sdk/execution_time/task_runner.py | 9 +-
.../src/airflow/sdk/execution_time}/timeout.py | 51 +---
.../tests/task_sdk/definitions/test_deadline.py | 265 ++++++++++++++++-----
113 files changed, 2545 insertions(+), 684 deletions(-)
copy
airflow-core/src/airflow/migrations/versions/{0079_3_1_0_add_callback_state_to_deadline.py
=> 0081_3_1_0_modify_deadline_callback_schema.py} (57%)
create mode 100644 airflow-core/src/airflow/ui/public/i18n/locales/pl/hitl.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-TW/hitl.json
copy airflow-core/src/airflow/ui/src/{components/ui/ActionBar =>
hooks/navigation}/index.ts (75%)
create mode 100644 airflow-core/src/airflow/ui/src/hooks/navigation/types.ts
create mode 100644
airflow-core/src/airflow/ui/src/hooks/navigation/useKeyboardNavigation.ts
create mode 100644
airflow-core/src/airflow/ui/src/hooks/navigation/useNavigation.ts
create mode 100644
providers/amazon/tests/system/amazon/aws/tests/test_lambda_executor_dlq.py
copy airflow-core/src/airflow/_vendor/__init__.py =>
providers/redis/any/dag_id=dag_for_testing_redis_task_handler/run_id=test/task_id=task_for_testing_redis_log_handler/attempt=1.log
(100%)
create mode 100644 providers/redis/docs/message-queues.rst
copy {airflow-core/src/airflow/_shared =>
providers/redis/src/airflow/providers/redis/queues}/__init__.py (100%)
copy
providers/{apache/kafka/src/airflow/providers/apache/kafka/queues/kafka.py =>
redis/src/airflow/providers/redis/queues/redis.py} (55%)
copy {airflow-core/src/airflow/_shared =>
providers/redis/tests/integration/redis/queues}/__init__.py (100%)
create mode 100644
providers/redis/tests/integration/redis/queues/test_redis_pubsub_message_queue.py
copy
providers/{common/messaging/tests/system/common/messaging/example_message_queue_trigger.py
=> redis/tests/system/redis/example_dag_message_queue_trigger.py} (78%)
copy {airflow-core/src/airflow/_shared =>
providers/redis/tests/unit/redis/queues}/__init__.py (100%)
copy providers/{apache/kafka/tests/unit/apache/kafka/queues/test_kafka.py =>
redis/tests/unit/redis/queues/test_redis.py} (63%)
copy {airflow-core/src/airflow/utils =>
task-sdk/src/airflow/sdk/execution_time}/timeout.py (57%)
