amoghrajesh commented on code in PR #67547:
URL: https://github.com/apache/airflow/pull/67547#discussion_r3309076929
##########
airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_state.py:
##########
@@ -127,7 +130,7 @@ def get_task_state(
detail=f"Task state key {key!r} not found",
)
return TaskStateResponse(
- key=row.key, value=row.value, updated_at=row.updated_at,
expires_at=row.expires_at
+ key=row.key, value=json.loads(row.value), updated_at=row.updated_at,
expires_at=row.expires_at
Review Comment:
Same as above. No such rows can exist since both write paths (execution API
and Core API PUT) always store `json.dumps(...)` before writing to the DB.
`json.loads` on the read path is always safe.
--
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]
