This is an automated email from the ASF dual-hosted git repository.
bbovenzi pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new 59cdedd0a7b Manually backport 54462: Filter out empty logs (#54628)
59cdedd0a7b is described below
commit 59cdedd0a7b006c63d9956692d9a668d579fc149
Author: Brent Bovenzi <[email protected]>
AuthorDate: Mon Aug 18 14:47:18 2025 -0500
Manually backport 54462: Filter out empty logs (#54628)
---
airflow-core/src/airflow/ui/src/queries/useLogs.tsx | 20 +++++++++++---------
1 file changed, 11 insertions(+), 9 deletions(-)
diff --git a/airflow-core/src/airflow/ui/src/queries/useLogs.tsx
b/airflow-core/src/airflow/ui/src/queries/useLogs.tsx
index 01b476f93c9..9657aabd5c6 100644
--- a/airflow-core/src/airflow/ui/src/queries/useLogs.tsx
+++ b/airflow-core/src/airflow/ui/src/queries/useLogs.tsx
@@ -57,17 +57,19 @@ const parseLogs = ({ data, logLevelFilters, sourceFilters,
taskInstance, tryNumb
const logLink = taskInstance ?
`${getTaskInstanceLink(taskInstance)}?try_number=${tryNumber}` : "";
try {
- parsedLines = data.map((datum, index) => {
- if (typeof datum !== "string" && "logger" in datum) {
- const source = datum.logger as string;
-
- if (!sources.includes(source)) {
- sources.push(source);
+ parsedLines = data
+ .map((datum, index) => {
+ if (typeof datum !== "string" && "logger" in datum) {
+ const source = datum.logger as string;
+
+ if (!sources.includes(source)) {
+ sources.push(source);
+ }
}
- }
- return renderStructuredLog({ index, logLevelFilters, logLink,
logMessage: datum, sourceFilters });
- });
+ return renderStructuredLog({ index, logLevelFilters, logLink,
logMessage: datum, sourceFilters });
+ })
+ .filter((parsedLine) => parsedLine !== "");
} catch (error) {
const errorMessage = error instanceof Error ? error.message : "An error
occurred.";