enhancement: improve DQ failure lineage tracing (#21022)

* enhancement: improve DQ failure lineage tracing

* Enhancement: Update lineage component to conditionally render controls and improve platform view handling in lineage provider. Added translations for platform-type lineage in multiple languages.

* Refactor LineageProvider to conditionally update history based on platform lineage and set default platform view in PlatformLineage component.

* minor fix

openmetadata-ui/src/main/resources/ui/src/components/Entity/EntityLineage/CustomEdge.component.tsx

@@ -95,6 +95,7 @@ export const CustomEdge = ({
     onAddPipelineClick,
     onColumnEdgeRemove,
     dataQualityLineage,
+    dqHighlightedEdges,
   } = useLineageProvider();
 
   const { theme } = useApplicationStore();
@@ -124,14 +125,15 @@ export const CustomEdge = ({
 
   // Compute if should show DQ tracing
   const showDqTracing = useMemo(() => {
-    return (
-      (activeLayer.includes(LineageLayer.DataObservability) &&
-        dataQualityLineage?.edges?.some(
-          (dqEdge) => dqEdge?.docId === edge?.docId
-        )) ??
-      false
-    );
-  }, [activeLayer, dataQualityLineage?.edges, edge?.docId]);
+    if (
+      !activeLayer.includes(LineageLayer.DataObservability) ||
+      !dataQualityLineage?.nodes
+    ) {
+      return false;
+    }
+
+    return dqHighlightedEdges?.has(id);
+  }, [activeLayer, dataQualityLineage?.nodes, id, dqHighlightedEdges]);
 
   // Determine if column is highlighted based on traced columns
   const isColumnHighlighted = useMemo(() => {

openmetadata-ui/src/main/resources/ui/src/components/Lineage/Lineage.component.tsx

@@ -164,7 +164,9 @@ const Lineage = ({
         ref={reactFlowWrapper}>
         {entityLineage && (
           <>
+            {isPlatformLineage ? null : (
               <CustomControlsComponent className="absolute top-1 right-1 p-xs" />
+            )}
             <LineageControlButtons
               deleted={deleted}
               entityType={entityType}

openmetadata-ui/src/main/resources/ui/src/context/LineageProvider/LineageProvider.interface.tsx

@@ -98,4 +98,5 @@ export interface LineageContextType {
   ) => void;
   onUpdateLayerView: (layers: LineageLayer[]) => void;
   redraw: () => Promise<void>;
+  dqHighlightedEdges?: Set<string>;
 }

openmetadata-ui/src/main/resources/ui/src/context/LineageProvider/LineageProvider.tsx

@@ -26,6 +26,7 @@ import React, {
   useState,
 } from 'react';
 import { useTranslation } from 'react-i18next';
+import { useHistory } from 'react-router-dom';
 import {
   Connection,
   Edge,
@@ -96,6 +97,7 @@ import {
   createNewEdge,
   createNodes,
   decodeLineageHandles,
+  getAllDownstreamEdges,
   getAllTracedColumnEdge,
   getClassifiedEdge,
   getConnectedNodesEdges,
@@ -135,6 +137,7 @@ const LineageProvider = ({ children }: LineageProviderProps) => {
   const { t } = useTranslation();
   const { fqn: decodedFqn } = useFqn();
   const location = useCustomLocation();
+  const history = useHistory();
   const { isTourOpen, isTourPage } = useTourProvider();
   const { appPreferences } = useApplicationStore();
   const defaultLineageConfig = appPreferences?.lineageConfig as LineageSettings;
@@ -197,6 +200,7 @@ const LineageProvider = ({ children }: LineageProviderProps) => {
   const backspacePressed = useKeyPress('Backspace');
   const { showModal } = useEntityExportModalProvider();
   const [isPlatformLineage, setIsPlatformLineage] = useState(false);
+  const [dqHighlightedEdges, setDqHighlightedEdges] = useState<Set<string>>();
 
   const lineageLayer = useMemo(() => {
     const param = location.search;
@@ -426,12 +430,29 @@ const LineageProvider = ({ children }: LineageProviderProps) => {
     [queryFilter, decodedFqn]
   );
 
-  const onPlatformViewChange = useCallback((view: LineagePlatformView) => {
+  const onPlatformViewChange = useCallback(
+    (view: LineagePlatformView) => {
       setPlatformView(view);
       if (view !== LineagePlatformView.None) {
         setActiveLayer([]);
       }
-  }, []);
+
+      if (isPlatformLineage) {
+        const searchData = QueryString.parse(
+          location.search.startsWith('?')
+            ? location.search.substring(1)
+            : location.search
+        );
+        history.push({
+          search: QueryString.stringify({
+            ...searchData,
+            platformView: view !== LineagePlatformView.None ? view : undefined,
+          }),
+        });
+      }
+    },
+    [isPlatformLineage, location.search]
+  );
 
   const exportLineageData = useCallback(
     async (_: string) => {
@@ -596,7 +617,7 @@ const LineageProvider = ({ children }: LineageProviderProps) => {
       setEntityType(entityType);
       setIsPlatformLineage(isPlatformLineage ?? false);
       if (isPlatformLineage && !entity) {
-        setPlatformView(LineagePlatformView.Service);
+        onPlatformViewChange(LineagePlatformView.Service);
       }
     },
     []
@@ -1527,6 +1548,7 @@ const LineageProvider = ({ children }: LineageProviderProps) => {
       dataQualityLineage,
       redraw,
       onPlatformViewChange,
+      dqHighlightedEdges,
     };
   }, [
     dataQualityLineage,
@@ -1575,6 +1597,7 @@ const LineageProvider = ({ children }: LineageProviderProps) => {
     onExportClick,
     redraw,
     onPlatformViewChange,
+    dqHighlightedEdges,
   ]);
 
   useEffect(() => {
@@ -1599,6 +1622,20 @@ const LineageProvider = ({ children }: LineageProviderProps) => {
     }
   }, [activeLayer, decodedFqn, lineageConfig]);
 
+  useEffect(() => {
+    if (
+      dataQualityLineage?.nodes &&
+      !isUndefined(edges) &&
+      isUndefined(dqHighlightedEdges)
+    ) {
+      const edgesToHighlight = dataQualityLineage.nodes
+        .flatMap((dqNode) => getAllDownstreamEdges(dqNode.id, edges ?? []))
+        .map((edge) => edge.id);
+      const edgesToHighlightSet = new Set(edgesToHighlight);
+      setDqHighlightedEdges(edgesToHighlightSet);
+    }
+  }, [dataQualityLineage, edges, dqHighlightedEdges]);
+
   return (
     <LineageContext.Provider value={activityFeedContextValues}>
       <div

openmetadata-ui/src/main/resources/ui/src/locale/languages/de-de.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Pipelines",
     "pipeline-state": "Pipeline-Status",
     "platform": "Plattform",
+    "platform-type-lineage": "{{platformType}} Abstammung",
     "play": "Abspielen",
     "please-enter-value": "Bitte einen Wert für {{name}} eingeben",
     "please-password-type-first": "Bitte zuerst das Passwort eingeben",

openmetadata-ui/src/main/resources/ui/src/locale/languages/en-us.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Pipelines",
     "pipeline-state": "Pipeline State",
     "platform": "Platform",
+    "platform-type-lineage": "{{platformType}} Lineage",
     "play": "Play",
     "please-enter-value": "Please enter {{name}} value",
     "please-password-type-first": "Please type password first",

openmetadata-ui/src/main/resources/ui/src/locale/languages/es-es.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Pipelines",
     "pipeline-state": "Estado de la pipeline",
     "platform": "Platform",
+    "platform-type-lineage": "{{platformType}} Linaje",
     "play": "Play",
     "please-enter-value": "Ingrese el valor de {{name}}",
     "please-password-type-first": "Ingrese primero la contraseña",

openmetadata-ui/src/main/resources/ui/src/locale/languages/fr-fr.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Pipelines",
     "pipeline-state": "État de la Pipeline",
     "platform": "Plateforme",
+    "platform-type-lineage": "{{platformType}} Lignage",
     "play": "Play",
     "please-enter-value": "Merci d'entrer une valeur pour {{name}} ",
     "please-password-type-first": "Merci d'entrer le mot de passe d'abord",

openmetadata-ui/src/main/resources/ui/src/locale/languages/gl-es.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Pipelines",
     "pipeline-state": "Estado do pipeline",
     "platform": "Plataforma",
+    "platform-type-lineage": "{{platformType}} Liñaxe",
     "play": "Reproducir",
     "please-enter-value": "Por favor, introduce o valor de {{name}}",
     "please-password-type-first": "Por favor, introduce primeiro o contrasinal",

openmetadata-ui/src/main/resources/ui/src/locale/languages/he-he.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "תהליכי טעינה/עיבוד",
     "pipeline-state": "מצב תהליך הטעינה/עיבוד",
     "platform": "Platform",
+    "platform-type-lineage": "{{platformType}} שורשים",
     "play": "Play",
     "please-enter-value": "נא להזין את ערך {{name}}",
     "please-password-type-first": "נא להקליד סיסמה תחילה",

openmetadata-ui/src/main/resources/ui/src/locale/languages/ja-jp.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "パイプライン",
     "pipeline-state": "パイプラインの状態",
     "platform": "Platform",
+    "platform-type-lineage": "{{platformType}} リネージ",
     "play": "Play",
     "please-enter-value": "{{name}}の値を入力してください",
     "please-password-type-first": "パスワードを入力してください",

openmetadata-ui/src/main/resources/ui/src/locale/languages/ko-kr.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "파이프라인들",
     "pipeline-state": "파이프라인 상태",
     "platform": "플랫폼",
+    "platform-type-lineage": "{{platformType}} 계보",
     "play": "재생",
     "please-enter-value": "{{name}} 값을 입력해주세요",
     "please-password-type-first": "먼저 비밀번호를 입력해주세요",

openmetadata-ui/src/main/resources/ui/src/locale/languages/mr-in.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "पाइपलाइन",
     "pipeline-state": "पाइपलाइन स्थिती",
     "platform": "प्लॅटफॉर्म",
+    "platform-type-lineage": "{{platformType}} वंशावळ",
     "play": "प्ले",
     "please-enter-value": "कृपया {{name}} मूल्य प्रविष्ट करा",
     "please-password-type-first": "कृपया प्रथम पासवर्ड टाइप करा",

openmetadata-ui/src/main/resources/ui/src/locale/languages/nl-nl.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Pipelines",
     "pipeline-state": "Pipelinestatus",
     "platform": "Platform",
+    "platform-type-lineage": "{{platformType}} Herkomst",
     "play": "Play",
     "please-enter-value": "Voer alstublieft de waarde voor {{name}} in",
     "please-password-type-first": "Typ eerst het wachtwoord alstublieft",

openmetadata-ui/src/main/resources/ui/src/locale/languages/pr-pr.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "خطوط لوله",
     "pipeline-state": "وضعیت خط لوله",
     "platform": "پلتفرم",
+    "platform-type-lineage": "{{platformType}} شجره داده",
     "play": "پخش",
     "please-enter-value": "لطفاً مقدار {{name}} را وارد کنید",
     "please-password-type-first": "لطفاً ابتدا رمز عبور را وارد کنید",

openmetadata-ui/src/main/resources/ui/src/locale/languages/pt-br.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Pipelines",
     "pipeline-state": "Estado do Pipeline",
     "platform": "Platform",
+    "platform-type-lineage": "{{platformType}} Linhagem",
     "play": "Play",
     "please-enter-value": "Por favor, insira o valor de {{name}}",
     "please-password-type-first": "Por favor, digite a senha primeiro",

openmetadata-ui/src/main/resources/ui/src/locale/languages/pt-pt.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Pipelines",
     "pipeline-state": "Estado do Pipeline",
     "platform": "Platform",
+    "platform-type-lineage": "{{platformType}} Linhagem",
     "play": "Play",
     "please-enter-value": "Por favor, insira o valor de {{name}}",
     "please-password-type-first": "Por favor, digite a senha primeiro",

openmetadata-ui/src/main/resources/ui/src/locale/languages/ru-ru.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "Пайплайны",
     "pipeline-state": "Состояние",
     "platform": "Platform",
+    "platform-type-lineage": "{{platformType}} Происхождение",
     "play": "Play",
     "please-enter-value": "Пожалуйста введите значение {{name}} ",
     "please-password-type-first": "Пожалуйста, сначала введите пароль",

openmetadata-ui/src/main/resources/ui/src/locale/languages/th-th.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "ท่อหลายรายการ",
     "pipeline-state": "สถานะท่อ",
     "platform": "แพลตฟอร์ม",
+    "platform-type-lineage": "{{platformType}} ลำดับชั้น",
     "play": "เล่น",
     "please-enter-value": "กรุณากรอกค่าของ {{name}}",
     "please-password-type-first": "กรุณาพิมพ์รหัสผ่านก่อน",

openmetadata-ui/src/main/resources/ui/src/locale/languages/zh-cn.json

@@ -1000,6 +1000,7 @@
     "pipeline-plural": "工作流",
     "pipeline-state": "工作流状态",
     "platform": "平台",
+    "platform-type-lineage": "{{platformType}} 血缘关系",
     "play": "Play",
     "please-enter-value": "请输入{{name}}值",
     "please-password-type-first": "请先输入密码",

openmetadata-ui/src/main/resources/ui/src/pages/PlatformLineage/PlatformLineage.tsx

@@ -13,7 +13,7 @@
 import { Col, Row, Select } from 'antd';
 import { DefaultOptionType } from 'antd/lib/select';
 import { AxiosError } from 'axios';
-import { debounce } from 'lodash';
+import { debounce, startCase } from 'lodash';
 import React, { useCallback, useEffect, useMemo, useState } from 'react';
 import { useTranslation } from 'react-i18next';
 import { useHistory, useParams } from 'react-router-dom';
@@ -27,6 +27,7 @@ import { SourceType } from '../../components/SearchedData/SearchedData.interface
 import { PAGE_SIZE_BASE } from '../../constants/constants';
 import { PAGE_HEADERS } from '../../constants/PageHeaders.constant';
 import LineageProvider from '../../context/LineageProvider/LineageProvider';
+import { LineagePlatformView } from '../../context/LineageProvider/LineageProvider.interface';
 import {
   OperationPermission,
   ResourceEntity,
@@ -34,6 +35,7 @@ import {
 import { EntityType } from '../../enums/entity.enum';
 import { SearchIndex } from '../../enums/search.enum';
 import { EntityReference } from '../../generated/entity/type';
+import useCustomLocation from '../../hooks/useCustomLocation/useCustomLocation';
 import { useFqn } from '../../hooks/useFqn';
 import { getEntityPermissionByFqn } from '../../rest/permissionAPI';
 import { searchQuery } from '../../rest/searchAPI';
@@ -45,7 +47,11 @@ import './platform-lineage.less';
 
 const PlatformLineage = () => {
   const { t } = useTranslation();
+  const location = useCustomLocation();
   const history = useHistory();
+  const queryParams = new URLSearchParams(location.search);
+  const platformView =
+    queryParams.get('platformView') ?? LineagePlatformView.Service;
   const { entityType } = useParams<{ entityType: EntityType }>();
   const { fqn: decodedFqn } = useFqn();
   const [selectedEntity, setSelectedEntity] = useState<SourceType>();
@@ -57,6 +63,16 @@ const PlatformLineage = () => {
   );
   const [permissions, setPermissions] = useState<OperationPermission>();
 
+  const handleEntitySelect = useCallback(
+    (value: EntityReference) => {
+      history.push(
+        `/lineage/${(value as SourceType).entityType}/${
+          value.fullyQualifiedName
+        }`
+      );
+    },
+    [history]
+  );
   const debouncedSearch = useCallback(
     debounce(async (value: string) => {
       try {
@@ -94,17 +110,6 @@ const PlatformLineage = () => {
     []
   );
 
-  const handleEntitySelect = useCallback(
-    (value: EntityReference) => {
-      history.push(
-        `/lineage/${(value as SourceType).entityType}/${
-          value.fullyQualifiedName
-        }`
-      );
-    },
-    [history]
-  );
-
   const init = useCallback(async () => {
     if (!decodedFqn || !entityType) {
       setDefaultValue(undefined);
@@ -169,7 +174,14 @@ const PlatformLineage = () => {
         <Col span={24}>
           <Row className="">
             <Col span={24}>
-              <PageHeader data={PAGE_HEADERS.PLATFORM_LINEAGE} />
+              <PageHeader
+                data={{
+                  ...PAGE_HEADERS.PLATFORM_LINEAGE,
+                  header: t('label.platform-type-lineage', {
+                    platformType: startCase(platformView),
+                  }),
+                }}
+              />
             </Col>
             <Col span={12}>
               <div className="m-t-md w-full">

openmetadata-ui/src/main/resources/ui/src/utils/EntityLineageUtils.tsx

@@ -1791,3 +1791,40 @@ export const getEntityTypeFromPlatformView = (
       return 'service';
   }
 };
+
+/**
+ * Recursively finds all downstream edges from a given node in a graph.
+ * This function traverses the graph depth-first, collecting all edges that flow downstream
+ * from the specified node while avoiding cycles by tracking visited nodes.
+ *
+ * @param {string} nodeId - The ID of the starting node
+ * @param {Edge[]} edges - Array of all edges in the graph
+ * @param {Set<string>} [visitedNodes=new Set()] - Set of already visited node IDs to prevent cycles
+ * @returns {Edge[]} Array of all downstream edges from the starting node
+ */
+export const getAllDownstreamEdges = (
+  nodeId: string,
+  edges: Edge[],
+  visitedNodes: Set<string> = new Set()
+): Edge[] => {
+  // If we've already visited this node, return empty array to avoid cycles
+  if (visitedNodes.has(nodeId)) {
+    return [];
+  }
+
+  visitedNodes.add(nodeId);
+
+  // Get direct downstream edges
+  const directDownstreamEdges = edges.filter((edge) => edge.source === nodeId);
+
+  // Get target nodes from direct downstream edges
+  const targetNodes = directDownstreamEdges.map((edge) => edge.target);
+
+  // Recursively get downstream edges for each target node
+  const nestedDownstreamEdges = targetNodes.flatMap((targetNodeId) =>
+    getAllDownstreamEdges(targetNodeId, edges, visitedNodes)
+  );
+
+  // Combine direct and nested downstream edges
+  return [...directDownstreamEdges, ...nestedDownstreamEdges];
+};