This is an automated email from the ASF dual-hosted git repository.
weilee pushed a change to branch render-json-logs-new-ui
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 4bc68d41607 test(providers/elasticsearch): fix part of the existing
unit test
omit 96531250356 feat(api_connexion/log): update v1 api to the latest log
format
omit fc69b843aac test(api_fastapi): fix existing test_log unit tests
omit 4749a53c1de test(www): fix existing unit tests
omit f02c8fa554f test(test_log_reader): fix existing unit tests
omit a2ba93e2ed6 style: improve type annotation
omit 0f4b2c62261 style: reduce if-else and directly use bool for assigning
metadata["download_logs"]
omit 2d007eb7a40 style: group metadata pop
omit f20a6fcbe77 Fix typescript useLogs
omit c80552007ab Render structured logs in the new UI rather than showing
raw JSON
add 7b123cd8198 Add link to latest dagrun in dags list. (#46907)
add f63652eca14 Make rendered_map_index default to map_index (#46918)
add d983b6ac946 Fix some warnings in React components (#46919)
add 9877491c159 Add a note `airflow users` command is available when FAB
auth-manager is enabled (#46862)
add dddcebc508c Give each tmux pane in `start-airflow` a title to make it
clear what is running (#46931)
add a29c840d938 Allow check_response to be defined in extra_options of
HTTP connection (#45451)
add c141383d5bf fix: api_version on on_kill method (#46833)
add ae2c59adbea Remove orphaned celery_command file (#46879)
add 3f548a01531 Bump trove-classifiers from 2025.1.15.22 to 2025.2.18.16
(#46903)
add b99cb7ce108 Create operators for working with Topics for GCP Apache
Kafka (#46865)
add d59d26e1f7b Remove references of "airflow.www" in FAB provider (#46914)
add 8f4fe3a6f6c Render structured logs in the new UI rather than showing
raw JSON
add af7b908e761 Fix typescript useLogs
add 6dee2dd047e style: group metadata pop
add 926c31ca0f5 style: reduce if-else and directly use bool for assigning
metadata["download_logs"]
add 2361547fa36 style: improve type annotation
add 50a4427e979 test(test_log_reader): fix existing unit tests
add 4b49860a3e2 test(www): fix existing unit tests
add e228104c1da test(api_fastapi): fix existing test_log unit tests
add 201e99df9eb feat(api_connexion/log): update v1 api to the latest log
format
add 10043f1864c test(providers/elasticsearch): fix part of the existing
unit test
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 (4bc68d41607)
\
N -- N -- N refs/heads/render-json-logs-new-ui (10043f1864c)
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:
.../api_connexion/schemas/task_instance_schema.py | 2 +-
.../cli/commands/local_commands/celery_command.py | 245 ---
airflow/models/dag.py | 2 +-
airflow/models/taskinstance.py | 14 +-
airflow/models/taskinstancehistory.py | 2 +-
airflow/ui/src/components/RenderedJsonField.tsx | 2 +-
.../ui/src/components/SearchDags/SearchDags.tsx | 1 +
airflow/ui/src/pages/Dag/Code/Code.tsx | 4 +-
airflow/ui/src/pages/DagsList/DagsList.tsx | 18 +-
airflow/ui/src/pages/Providers.tsx | 2 +-
airflow/ui/src/pages/TaskInstance/Details.tsx | 6 +-
contributing-docs/03_contributors_quick_start.rst | 2 +
.../contributors_quick_start_gitpod.rst | 3 +
docs/apache-airflow/start.rst | 3 +
generated/provider_dependencies.json | 2 +-
.../airflow/providers/airbyte/operators/airbyte.py | 2 +-
.../tests/unit/airbyte/operators/test_airbyte.py | 17 +
providers/apache/livy/README.rst | 2 +-
providers/apache/livy/pyproject.toml | 2 +-
.../providers/apache/livy/get_provider_info.py | 2 +-
.../airflow/providers/apache/livy/hooks/livy.py | 15 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 8 +-
.../fab/auth_manager/security_manager/override.py | 2 +-
.../providers/fab/www/api_connexion/exceptions.py | 41 +-
providers/fab/src/airflow/providers/fab/www/app.py | 16 +-
.../fab/www/extensions/init_appbuilder.py | 12 +
.../providers/fab/www/extensions/init_views.py | 85 +-
.../fab/src/airflow/providers/fab/www/views.py | 59 +-
.../api/auth/backend/test_basic_auth.py | 4 +-
.../auth_manager/api/auth/backend/test_session.py | 4 +-
.../api_endpoints/test_asset_endpoint.py | 325 ----
.../fab/auth_manager/api_endpoints/test_auth.py | 102 +-
.../fab/auth_manager/api_endpoints/test_cors.py | 155 --
.../api_endpoints/test_dag_endpoint.py | 226 ---
.../api_endpoints/test_dag_run_endpoint.py | 277 ----
.../api_endpoints/test_dag_source_endpoint.py | 132 --
.../api_endpoints/test_dag_warning_endpoint.py | 84 --
.../api_endpoints/test_event_log_endpoint.py | 151 --
.../api_endpoints/test_import_error_endpoint.py | 244 ---
.../api_endpoints/test_task_instance_endpoint.py | 428 ------
.../api_endpoints/test_variable_endpoint.py | 88 --
.../api_endpoints/test_xcom_endpoint.py | 282 ----
.../fab/tests/unit/fab/auth_manager/conftest.py | 4 +-
.../unit/fab/auth_manager/test_fab_auth_manager.py | 4 +-
.../tests/unit/fab/auth_manager/test_security.py | 88 +-
.../fab/auth_manager/views/test_permissions.py | 4 +-
.../unit/fab/auth_manager/views/test_roles_list.py | 4 +-
.../tests/unit/fab/auth_manager/views/test_user.py | 4 +-
.../unit/fab/auth_manager/views/test_user_edit.py | 4 +-
.../unit/fab/auth_manager/views/test_user_stats.py | 4 +-
providers/fab/tests/unit/fab/www/views/conftest.py | 4 +-
.../fab/tests/unit/fab/www/views/test_views_acl.py | 1576 --------------------
.../fab/www/views/test_views_custom_user_views.py | 29 +-
.../google/docs/operators/cloud/managed_kafka.rst | 48 +
providers/google/provider.yaml | 1 +
.../providers/google/cloud/hooks/managed_kafka.py | 198 ++-
.../providers/google/cloud/links/managed_kafka.py | 29 +
.../google/cloud/operators/managed_kafka.py | 337 +++++
.../airflow/providers/google/get_provider_info.py | 1 +
...a_cluster.py => example_managed_kafka_topic.py} | 100 +-
.../unit/google/cloud/hooks/test_managed_kafka.py | 246 +++
.../unit/google/cloud/links/test_managed_kafka.py | 38 +
.../google/cloud/operators/test_managed_kafka.py | 172 +++
providers/http/README.rst | 6 +-
providers/http/docs/index.rst | 2 +-
providers/http/provider.yaml | 1 +
providers/http/pyproject.toml | 6 +-
.../http/src/airflow/providers/http/__init__.py | 2 +-
.../airflow/providers/http/get_provider_info.py | 1 +
.../http/src/airflow/providers/http/hooks/http.py | 127 +-
providers/http/tests/unit/http/hooks/test_http.py | 150 +-
.../http/tests/unit/http/sensors/test_http.py | 18 +-
pyproject.toml | 2 +-
.../ci/pre_commit/check_ti_vs_tis_attributes.py | 1 +
scripts/cov/cli_coverage.py | 1 -
scripts/in_container/bin/run_tmux | 11 +
.../test_mapped_task_instance_endpoint.py | 2 +-
.../endpoints/test_task_instance_endpoint.py | 4 +-
.../core_api/routes/public/test_task_instances.py | 6 +-
.../commands/local_commands/test_celery_command.py | 361 -----
.../cli/commands/test_celery_command.py | 6 +-
tests/models/test_taskinstance.py | 2 +-
82 files changed, 1631 insertions(+), 5046 deletions(-)
delete mode 100644 airflow/cli/commands/local_commands/celery_command.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_asset_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_cors.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_dag_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_dag_run_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_dag_source_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_dag_warning_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_event_log_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_import_error_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_task_instance_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_variable_endpoint.py
delete mode 100644
providers/fab/tests/unit/fab/auth_manager/api_endpoints/test_xcom_endpoint.py
delete mode 100644 providers/fab/tests/unit/fab/www/views/test_views_acl.py
copy
providers/google/tests/system/google/cloud/managed_kafka/{example_managed_kafka_cluster.py
=> example_managed_kafka_topic.py} (57%)
delete mode 100644 tests/cli/commands/local_commands/test_celery_command.py
