diff --git a/airflow-core/src/airflow/ui/src/queries/useLogs.tsx b/airflow-core/src/airflow/ui/src/queries/useLogs.tsx index 01b476f93c957..9657aabd5c660 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.";