This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 973640e03fe Fix bulk task instance authorization error message 
rendering (#64719)
973640e03fe is described below

commit 973640e03fef11e8a84edeccbf7d9e96fc2106b7
Author: Jarek Potiuk <[email protected]>
AuthorDate: Sat Apr 4 16:50:01 2026 +0200

    Fix bulk task instance authorization error message rendering (#64719)
    
    BulkAction enum values were rendered as "BulkAction.UPDATE" / 
"BulkAction.DELETE"
    instead of "update" / "delete" in authorization error messages because 
Python's
    str enum __format__ returns the enum repr, not the value. Use .value to get 
the
    plain string.
---
 .../airflow/api_fastapi/core_api/services/public/task_instances.py    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/airflow-core/src/airflow/api_fastapi/core_api/services/public/task_instances.py
 
b/airflow-core/src/airflow/api_fastapi/core_api/services/public/task_instances.py
index ce7f1a98964..08aeac4812c 100644
--- 
a/airflow-core/src/airflow/api_fastapi/core_api/services/public/task_instances.py
+++ 
b/airflow-core/src/airflow/api_fastapi/core_api/services/public/task_instances.py
@@ -342,7 +342,7 @@ class 
BulkTaskInstanceService(BulkService[BulkTaskInstanceBody]):
         """Bulk Update Task Instances."""
         # Validate and categorize entities into specific and all map index 
update sets
         update_specific_map_index_task_keys, update_all_map_index_task_keys = 
self._categorize_entities(
-            action.entities, results, method="PUT", action_name=action.action
+            action.entities, results, method="PUT", 
action_name=action.action.value
         )
 
         try:
@@ -444,7 +444,7 @@ class 
BulkTaskInstanceService(BulkService[BulkTaskInstanceBody]):
         """Bulk delete task instances."""
         # Validate and categorize entities into specific and all map index 
delete sets
         delete_specific_map_index_task_keys, delete_all_map_index_task_keys = 
self._categorize_entities(
-            action.entities, results, method="DELETE", 
action_name=action.action
+            action.entities, results, method="DELETE", 
action_name=action.action.value
         )
 
         try:

Reply via email to