Skip to content

Commit 59cdedd

Browse files
authored
Manually backport 54462: Filter out empty logs (#54628)
1 parent b28d3a6 commit 59cdedd

File tree

1 file changed

+11
-9
lines changed

1 file changed

+11
-9
lines changed

airflow-core/src/airflow/ui/src/queries/useLogs.tsx

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -57,17 +57,19 @@ const parseLogs = ({ data, logLevelFilters, sourceFilters, taskInstance, tryNumb
5757
const logLink = taskInstance ? `${getTaskInstanceLink(taskInstance)}?try_number=${tryNumber}` : "";
5858

5959
try {
60-
parsedLines = data.map((datum, index) => {
61-
if (typeof datum !== "string" && "logger" in datum) {
62-
const source = datum.logger as string;
63-
64-
if (!sources.includes(source)) {
65-
sources.push(source);
60+
parsedLines = data
61+
.map((datum, index) => {
62+
if (typeof datum !== "string" && "logger" in datum) {
63+
const source = datum.logger as string;
64+
65+
if (!sources.includes(source)) {
66+
sources.push(source);
67+
}
6668
}
67-
}
6869

69-
return renderStructuredLog({ index, logLevelFilters, logLink, logMessage: datum, sourceFilters });
70-
});
70+
return renderStructuredLog({ index, logLevelFilters, logLink, logMessage: datum, sourceFilters });
71+
})
72+
.filter((parsedLine) => parsedLine !== "");
7173
} catch (error) {
7274
const errorMessage = error instanceof Error ? error.message : "An error occurred.";
7375

0 commit comments

Comments
 (0)