This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 45364e55cc0 Add release notes for 3.1.0b1
omit 8bf963c9d84 Pin Task-SDK for Airflow meta package
omit 4fdfdc10f37 Update default branches for 3-1
new 957fc1c2388 Switch all airflow logging to structlog (#52651)
new 3aa105685e4 Add guards for registering middlewares from plugins
(#55399)
new 36add023a70 Allow attachment of multiple deadlines to a DAG (#55086)
new bb53eedfdda Optimize Gantt group expansion with debouncing and
deferred rendering (#55334)
new 5cfba2bbaba Fix graph export cropping when view is partial (#55012)
new bcd0d090058 Complete Arabic translation 2025-09-09 (#55435)
new f93fef8b8d1 Fix Dag processor crashing under `airflow standalone`
(#55434)
new ab828974e95 [I18N] Add Simplified Chinese (zh-CN) UI Translation
(#55122)
new 0e4cbef8bd6 Fixup to structlog migration - logging folder not being
created correctly. (#55431)
new 84661e28af0 Fix static checks in boring-cyborg.yml (#55441)
new e21835c19d6 chore(ui): add bottom padding to DAG list (#55415)
new 6e2da13837c Update default branches for 3-1
new d3f6d90c165 Pin Task-SDK for Airflow meta package
new a701a3756df Add release notes for 3.1.0b1
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 (45364e55cc0)
\
N -- N -- N refs/heads/v3-1-test (a701a3756df)
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.
The 14 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/CODEOWNERS | 2 +
.github/boring-cyborg.yml | 5 +-
RELEASE_NOTES.rst | 8 +-
airflow-core/pyproject.toml | 11 +-
airflow-core/src/airflow/_shared/logging | 1 +
airflow-core/src/airflow/api_fastapi/app.py | 4 +
.../airflow/cli/commands/dag_processor_command.py | 3 +-
.../config_templates/airflow_local_settings.py | 3 +-
.../src/airflow/dag_processing/collection.py | 4 +-
airflow-core/src/airflow/dag_processing/manager.py | 28 +-
.../src/airflow/jobs/scheduler_job_runner.py | 4 +-
.../src/airflow/jobs/triggerer_job_runner.py | 18 +-
airflow-core/src/airflow/logging_config.py | 33 +-
airflow-core/src/airflow/models/dag.py | 17 +-
airflow-core/src/airflow/models/dagrun.py | 10 +-
airflow-core/src/airflow/serialization/schema.json | 4 +
.../airflow/serialization/serialized_objects.py | 43 +-
.../airflow/ui/public/i18n/locales/ar/common.json | 3 +-
.../ui/public/i18n/locales/zh-CN/admin.json | 167 ++++++
.../ui/public/i18n/locales/zh-CN/assets.json | 30 ++
.../ui/public/i18n/locales/zh-CN/browse.json | 26 +
.../ui/public/i18n/locales/zh-CN/common.json | 315 +++++++++++
.../ui/public/i18n/locales/zh-CN/components.json | 134 +++++
.../airflow/ui/public/i18n/locales/zh-CN/dag.json | 149 ++++++
.../airflow/ui/public/i18n/locales/zh-CN/dags.json | 97 ++++
.../ui/public/i18n/locales/zh-CN/dashboard.json | 45 ++
.../airflow/ui/public/i18n/locales/zh-CN/hitl.json | 31 ++
.../ui/public/i18n/locales/zh-CN/tasks.json | 10 +
.../ui/src/components/Graph/DownloadButton.tsx | 15 +-
.../src/context/openGroups/OpenGroupsProvider.tsx | 32 +-
airflow-core/src/airflow/ui/src/i18n/config.ts | 3 +-
.../airflow/ui/src/layouts/Details/Gantt/Gantt.tsx | 8 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 2 +-
airflow-core/src/airflow/utils/cli.py | 11 +
.../airflow/utils/log/file_processor_handler.py | 4 +-
airflow-core/src/airflow/utils/log/log_reader.py | 7 +-
.../src/airflow/utils/log/logging_mixin.py | 16 +-
airflow-core/src/airflow/utils/retries.py | 11 +-
.../tests/integration/otel/dags/otel_test_dag.py | 2 +-
airflow-core/tests/integration/otel/test_otel.py | 6 +-
.../tests/unit/always/test_providers_manager.py | 18 +-
.../api_fastapi/core_api/routes/public/test_log.py | 19 +-
.../tests/unit/cli/commands/test_task_command.py | 3 -
airflow-core/tests/unit/cli/conftest.py | 16 +-
.../tests/unit/core/test_logging_config.py | 422 ---------------
airflow-core/tests/unit/core/test_stats.py | 8 +-
.../tests/unit/dag_processing/test_manager.py | 3 -
airflow-core/tests/unit/models/test_dag.py | 61 ++-
.../unit/serialization/test_dag_serialization.py | 6 -
airflow-core/tests/unit/task/conftest.py | 7 -
.../tests/unit/utils/log/test_log_reader.py | 28 +-
airflow-core/tests/unit/utils/test_log_handlers.py | 6 +-
.../tests/unit/utils/test_logging_mixin.py | 12 -
.../tests/unit/utils/test_process_utils.py | 11 +-
airflow-core/tests/unit/utils/test_retries.py | 2 +-
.../test_task_handler_with_custom_formatter.py | 113 ----
.../src/airflow_breeze/utils/selective_checks.py | 75 ---
dev/breeze/tests/test_selective_checks.py | 240 +--------
dev/i18n/check_translations_completeness.py | 1 +
devel-common/src/tests_common/pytest_plugin.py | 142 +++--
devel-common/src/tests_common/test_utils/logs.py | 244 +++++++++
.../test_kubernetes_pod_operator.py | 33 +-
.../src/airflow/providers/amazon/aws/hooks/glue.py | 2 +-
.../providers/amazon/aws/utils/task_log_fetcher.py | 2 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 9 +-
.../unit/amazon/aws/log/test_s3_task_handler.py | 41 +-
.../airflow/providers/apache/beam/hooks/beam.py | 8 +-
.../apache/flink/sensors/test_flink_kubernetes.py | 28 +-
.../unit/celery/log_handlers/test_log_handlers.py | 2 -
.../kubernetes/log_handlers/test_log_handlers.py | 5 +-
.../kubernetes/sensors/test_spark_kubernetes.py | 27 +-
.../sql/tests/unit/common/sql/hooks/test_dbapi.py | 8 +-
.../sql/tests/unit/common/sql/hooks/test_sql.py | 2 -
.../providers/databricks/operators/databricks.py | 9 +-
.../databricks/plugins/databricks_workflow.py | 12 +-
.../tests/unit/databricks/hooks/test_databricks.py | 1 -
.../airflow/providers/docker/operators/docker.py | 9 +-
.../tests/unit/docker/decorators/test_docker.py | 16 +-
.../google/cloud/utils/bigquery_get_data.py | 2 +-
.../microsoft/azure/log/test_wasb_task_handler.py | 26 +-
.../airflow/providers/microsoft/psrp/hooks/psrp.py | 12 +-
.../unit/microsoft/psrp/operators/test_psrp.py | 2 +-
.../providers/snowflake/hooks/snowflake_sql_api.py | 2 +-
.../ssh/src/airflow/providers/ssh/hooks/ssh.py | 6 +
.../tests/unit/standard/operators/test_python.py | 17 +-
pyproject.toml | 9 +-
reproducible_build.yaml | 4 +-
shared/{timezones => logging}/pyproject.toml | 9 +-
.../src/airflow_shared/logging}/__init__.py | 9 +-
.../src/airflow_shared/logging/_noncaching.py | 34 +-
.../airflow_shared/logging/percent_formatter.py | 153 ++++++
.../src/airflow_shared/logging/structlog.py | 588 +++++++++++++++++++++
shared/logging/src/airflow_shared/logging/types.py | 43 ++
shared/logging/tests/logging/test_structlog.py | 282 ++++++++++
task-sdk/pyproject.toml | 9 +-
task-sdk/src/airflow/sdk/_shared/logging | 1 +
.../src/airflow/sdk/definitions/_internal/node.py | 11 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 45 +-
.../airflow/sdk/execution_time/execute_workload.py | 2 +-
.../src/airflow/sdk/execution_time/supervisor.py | 19 +-
.../src/airflow/sdk/execution_time/task_runner.py | 2 +-
task-sdk/src/airflow/sdk/log.py | 411 ++++----------
task-sdk/src/airflow/sdk/types.py | 1 +
task-sdk/tests/conftest.py | 30 +-
task-sdk/tests/task_sdk/bases/test_operator.py | 28 +-
.../tests/task_sdk/definitions/test_xcom_arg.py | 82 ++-
task-sdk/tests/task_sdk/log/test_log.py | 225 --------
107 files changed, 3110 insertions(+), 1927 deletions(-)
create mode 120000 airflow-core/src/airflow/_shared/logging
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/admin.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/assets.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/browse.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/common.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/components.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/dag.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/dags.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/dashboard.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/hitl.json
create mode 100644
airflow-core/src/airflow/ui/public/i18n/locales/zh-CN/tasks.json
delete mode 100644 airflow-core/tests/unit/core/test_logging_config.py
delete mode 100644
airflow-core/tests/unit/utils/test_task_handler_with_custom_formatter.py
copy shared/{timezones => logging}/pyproject.toml (89%)
copy {airflow-core/src/airflow/utils/serve_logs =>
shared/logging/src/airflow_shared/logging}/__init__.py (84%)
copy providers/sendgrid/src/airflow/providers/sendgrid/version_compat.py =>
shared/logging/src/airflow_shared/logging/_noncaching.py (59%)
create mode 100644
shared/logging/src/airflow_shared/logging/percent_formatter.py
create mode 100644 shared/logging/src/airflow_shared/logging/structlog.py
create mode 100644 shared/logging/src/airflow_shared/logging/types.py
create mode 100644 shared/logging/tests/logging/test_structlog.py
create mode 120000 task-sdk/src/airflow/sdk/_shared/logging
delete mode 100644 task-sdk/tests/task_sdk/log/test_log.py
