dheerajturaga opened a new pull request, #56605:
URL: https://github.com/apache/airflow/pull/56605
When querying the API endpoint for mapped tasks (e.g.,
/api/v2/dags/{dag_id}/tasks/{task_id}),
the server returned a 500 Internal Server Error if the mapped task didn't
have an explicit
retry_delay set. The retry_delay property was using direct dictionary access
which raised
a KeyError during serialization.
Changed to use .get() with the default value from SerializedBaseOperator
(300 seconds)
```
INFO: 172.18.0.1:47834 - "GET
/api/v2/dags/example_dv_simulation_flow/tasks/run_simulation HTTP/1.1" 500
Internal Server Error
ERROR: Exception in ASGI application
raise ResponseValidationError(
fastapi.exceptions.ResponseValidationError: 1 validation errors:
{'type': 'get_attribute_error', 'loc': ('response', 'retry_delay'), 'msg':
"Error extracting attribute: KeyError: 'retry_delay'", 'input':
<SerializedMappedTask(_PythonDecoratedOperator): run_simulation>, 'ctx':
{'error': "KeyError: 'retry_delay'"}}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
