diff --git a/airflow/www/static/js/components/DatasetEventCard.tsx b/airflow/www/static/js/components/DatasetEventCard.tsx index ee00def48d6b9b..e5fa2bc22c51e7 100644 --- a/airflow/www/static/js/components/DatasetEventCard.tsx +++ b/airflow/www/static/js/components/DatasetEventCard.tsx @@ -44,11 +44,17 @@ import TriggeredDagRuns from "./TriggeredDagRuns"; type CardProps = { datasetEvent: DatasetEvent; + showSource?: boolean; + showTriggeredDagRuns?: boolean; }; const datasetsUrl = getMetaValue("datasets_url"); -const DatasetEventCard = ({ datasetEvent }: CardProps) => { +const DatasetEventCard = ({ + datasetEvent, + showSource = true, + showTriggeredDagRuns = true, +}: CardProps) => { const [searchParams] = useSearchParams(); const selectedUri = decodeURIComponent(searchParams.get("uri") || ""); @@ -92,25 +98,29 @@ const DatasetEventCard = ({ datasetEvent }: CardProps) => { - Source: - {fromRestApi && ( - - - - - - )} - {!!datasetEvent.sourceTaskId && ( - + {showSource && ( + <> + Source: + {fromRestApi && ( + + + + + + )} + {!!datasetEvent.sourceTaskId && ( + + )} + )} - {!!datasetEvent?.createdDagruns?.length && ( + {showTriggeredDagRuns && !!datasetEvent?.createdDagruns?.length && ( <> Triggered Dag Runs: diff --git a/airflow/www/static/js/dag/details/dagRun/DatasetTriggerEvents.tsx b/airflow/www/static/js/dag/details/dagRun/DatasetTriggerEvents.tsx index b9d0c1c169161e..5fa585830b437d 100644 --- a/airflow/www/static/js/dag/details/dagRun/DatasetTriggerEvents.tsx +++ b/airflow/www/static/js/dag/details/dagRun/DatasetTriggerEvents.tsx @@ -33,7 +33,9 @@ interface Props { const dagId = getMetaValue("dag_id"); const cardDef: CardDef = { - card: ({ row }) => , + card: ({ row }) => ( + + ), }; const DatasetTriggerEvents = ({ runId }: Props) => { @@ -56,10 +58,6 @@ const DatasetTriggerEvents = ({ runId }: Props) => { Header: "Source Task Instance", accessor: "sourceTaskId", }, - { - Header: "Triggered Runs", - accessor: "createdDagruns", - }, { Header: "Extra", accessor: "extra", diff --git a/airflow/www/static/js/dag/details/taskInstance/DatasetUpdateEvents.tsx b/airflow/www/static/js/dag/details/taskInstance/DatasetUpdateEvents.tsx index bbcf5886853bd8..48c987a829601a 100644 --- a/airflow/www/static/js/dag/details/taskInstance/DatasetUpdateEvents.tsx +++ b/airflow/www/static/js/dag/details/taskInstance/DatasetUpdateEvents.tsx @@ -32,7 +32,7 @@ interface Props { } const cardDef: CardDef = { - card: ({ row }) => , + card: ({ row }) => , }; const dagId = getMetaValue("dag_id") || undefined; @@ -57,10 +57,6 @@ const DatasetUpdateEvents = ({ runId, taskId }: Props) => { Header: "Dataset", accessor: "datasetUri", }, - { - Header: "Source Task Instance", - accessor: "sourceTaskId", - }, { Header: "Triggered Runs", accessor: "createdDagruns",