The GitHub Actions job "Tests (AMD)" on 
airflow.git/fix/es-log-handler-malformed-log-entry has failed.
Run started by GitHub user hkc-8010 (triggered by hkc-8010).

Head commit for run:
8c4fdb65c756a6af5e87425aaf18809b8a58b4cb / Hemkumar Chheda 
<[email protected]>
Prevent malformed Elasticsearch log entries from crashing task log fetch

A single stored log entry with a non-string `event` field (for example,
a task that logs a list or dict as the sole message argument) currently
crashes the entire task-log-fetch request with an unhandled
pydantic.ValidationError, instead of degrading gracefully.

_read() built StructuredLogMessage objects from stored Elasticsearch
hits without catching validation failures. This catches ValidationError
per hit and falls back to a stringified event, matching the existing
fallback pattern in file_task_handler.py's _log_stream_to_parsed_log_stream.

closes: #69304

Report URL: https://github.com/apache/airflow/actions/runs/28645592305

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to