diff --git a/airflow-core/src/airflow/ui/src/queries/useLogs.tsx b/airflow-core/src/airflow/ui/src/queries/useLogs.tsx index fae844637890d..a7f96d9557db2 100644 --- a/airflow-core/src/airflow/ui/src/queries/useLogs.tsx +++ b/airflow-core/src/airflow/ui/src/queries/useLogs.tsx @@ -72,26 +72,28 @@ const parseLogs = ({ 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; + 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); + if (!sources.includes(source)) { + sources.push(source); + } } - } - return renderStructuredLog({ - index, - logLevelFilters, - logLink, - logMessage: datum, - showSource, - showTimestamp, - sourceFilters, - translate, - }); - }); + return renderStructuredLog({ + index, + logLevelFilters, + logLink, + logMessage: datum, + showSource, + showTimestamp, + sourceFilters, + translate, + }); + }) + .filter((parsedLine) => parsedLine !== ""); } catch (error) { const errorMessage = error instanceof Error ? error.message : "An error occurred.";