62:I[707087,["/_next/static/immutable/chunks/3arlv5bvukoo2.js","/_next/static/immutable/chunks/39v64hmfyo-sr.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/04j_o97cgxn2x.js","/_next/static/immutable/chunks/3upr08c9vtj8w.js","/_next/static/immutable/chunks/1ww0328si-u8x.js","/_next/static/immutable/chunks/11mfl5ymqld9-.js","/_next/static/immutable/chunks/2xxcqy6ppds3l.js","/_next/static/immutable/chunks/1bpgyrs5qflhu.js","/_next/static/immutable/chunks/0-6vu2ul1h6ld.js","/_next/static/immutable/chunks/43_s7jweyypoh.js","/_next/static/immutable/chunks/0p6vao205o1jc.js","/_next/static/immutable/chunks/1_kyvgkyokw92.js","/_next/static/immutable/chunks/1lo-zn37dolb5.js","/_next/static/immutable/chunks/1v8k6yxw1rg0u.js"],"RegistryDependencies"] 63:I[314491,["/_next/static/immutable/chunks/3arlv5bvukoo2.js","/_next/static/immutable/chunks/39v64hmfyo-sr.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/04j_o97cgxn2x.js","/_next/static/immutable/chunks/3upr08c9vtj8w.js","/_next/static/immutable/chunks/1ww0328si-u8x.js","/_next/static/immutable/chunks/11mfl5ymqld9-.js","/_next/static/immutable/chunks/2xxcqy6ppds3l.js","/_next/static/immutable/chunks/1bpgyrs5qflhu.js","/_next/static/immutable/chunks/0-6vu2ul1h6ld.js","/_next/static/immutable/chunks/43_s7jweyypoh.js","/_next/static/immutable/chunks/0p6vao205o1jc.js","/_next/static/immutable/chunks/1_kyvgkyokw92.js","/_next/static/immutable/chunks/1lo-zn37dolb5.js","/_next/static/immutable/chunks/1v8k6yxw1rg0u.js"],"FilesView"] 64:Tacbf,'use client' import * as React from 'react' import { Activity, AlertCircle, AlertTriangle, Check, CheckCircle2, Clock, Copy, Database, Download, FileCode2, Filter, GitBranch, Layers, RefreshCw, Search, ShieldCheck, } from 'lucide-react' import { cn } from '@/lib/utils' import { Badge } from '@/components/ui/badge' import { Button } from '@/components/ui/button' import { Card, CardContent, CardDescription, CardHeader, CardTitle } from '@/components/ui/card' import { Progress } from '@/components/ui/progress' import { Separator } from '@/components/ui/separator' import { Sheet, SheetClose, SheetContent, SheetDescription, SheetFooter, SheetHeader, SheetTitle, } from '@/components/ui/sheet' import { Table, TableBody, TableCell, TableHead, TableHeader, TableRow } from '@/components/ui/table' export type AssertionStatus = 'Passing' | 'Warning' | 'Failed' export type AssertionCategory = 'Completeness' | 'Uniqueness' | 'Validity' | 'Volume' | 'Schema' export interface AnomalyRecord { recordId: string column: string value: string reason: string } export interface AssertionItem { id: string assertionType: string columnName: string category: AssertionCategory ruleDefinition: string targetThreshold: string observedValue: string observedPercent: number failedCount: number totalEvaluated: number status: AssertionStatus statusVariant: 'success' | 'warning' | 'destructive' executionTime: string expectationConfig: Record remediationQuery: string anomalies: AnomalyRecord[] } export interface DataQualityMetricsProps { datasetTitle?: string suiteName?: string qualityScore?: number lastRun?: string passedAssertions?: string failedWarnings?: string schemaDriftStatus?: string totalRowsAudited?: string assertions?: AssertionItem[] className?: string } const defaultAssertions: AssertionItem[] = [ { id: 'dq-assert-1', assertionType: 'expect_column_values_to_not_be_null', columnName: 'user_id', category: 'Completeness', ruleDefinition: 'Primary key non-null identity constraint verification across all partition shards.', targetThreshold: '100.0%', observedValue: '100.0%', observedPercent: 100.0, failedCount: 0, totalEvaluated: 1480000, status: 'Passing', statusVariant: 'success', executionTime: '142ms', expectationConfig: { expectation_type: 'expect_column_values_to_not_be_null', kwargs: { column: 'user_id', mostly: 1.0, }, }, remediationQuery: `-- Primary key check passed cleanly. No quarantine needed.\nSELECT COUNT(*) FROM production_analytics.dim_users WHERE user_id IS NULL;`, anomalies: [], }, { id: 'dq-assert-2', assertionType: 'expect_column_values_to_be_unique', columnName: 'email', category: 'Uniqueness', ruleDefinition: 'Global case-insensitive deduplication check across customer directory.', targetThreshold: '100.0%', observedValue: '100.0%', observedPercent: 100.0, failedCount: 0, totalEvaluated: 1480000, status: 'Passing', statusVariant: 'success', executionTime: '380ms', expectationConfig: { expectation_type: 'expect_column_values_to_be_unique', kwargs: { column: 'email', mostly: 1.0, }, }, remediationQuery: `-- Zero duplicate emails detected in active partition.\nSELECT LOWER(email), COUNT(*) FROM production_analytics.dim_users GROUP BY 1 HAVING COUNT(*) > 1;`, anomalies: [], }, { id: 'dq-assert-3', assertionType: 'expect_column_values_to_match_regex', columnName: 'phone_e164', category: 'Validity', ruleDefinition: 'International telecommunications ITU-T E.164 format pattern matching (^\\+[1-9]\\d{1,14}$).', targetThreshold: '≥ 98.0%', observedValue: '98.8%', observedPercent: 98.8, failedCount: 17760, totalEvaluated: 1480000, status: 'Warning', statusVariant: 'warning', executionTime: '890ms', expectationConfig: { expectation_type: 'expect_column_values_to_match_regex', kwargs: { column: 'phone_e164', regex: '^\\+[1-9]\\d{1,14}$', mostly: 0.98, }, }, remediationQuery: `-- Quarantine 17,760 legacy unformatted phone numbers for libphonenumber normalization:\nCREATE OR REPLACE TABLE staging.unformatted_phones AS\nSELECT user_id, email, phone_e164, 'MALFORMED_E164' AS failure_reason\nFROM production_analytics.dim_users\nWHERE phone_e164 NOT RLIKE '^\\+[1-9]\\d{1,14}$';`, anomalies: [ { recordId: 'usr_9941a8', column: 'phone_e164', value: '+1-555-019', reason: 'Invalid E.164 length (incomplete national number)', }, { recordId: 'usr_1082fc', column: 'phone_e164', value: '0784910293', reason: 'Missing international country dial prefix (+)', }, { recordId: 'usr_7729de', column: 'phone_e164', value: '+44 (0)20 7946', reason: 'Unstripped parentheses and whitespace delimiter', }, { recordId: 'usr_4019ab', column: 'phone_e164', value: 'NULL', reason: 'Unexpected empty field on SMS-enrolled user', }, ], }, { id: 'dq-assert-4', assertionType: 'expect_table_row_count_to_be_between', columnName: 'table: dim_users', category: 'Volume', ruleDefinition: 'Daily snapshot table row count volumetric boundary expectation between 1.0M and 2.0M rows.', targetThreshold: '1.0M .. 2.0M', observedValue: '1,480,000', observedPercent: 100.0, failedCount: 0, totalEvaluated: 1480000, status: 'Passing', statusVariant: 'success', executionTime: '95ms', expectationConfig: { expectation_type: 'expect_table_row_count_to_be_between', kwargs: { min_value: 1000000, max_value: 2000000, }, }, remediationQuery: `-- Row count volumetric validation passed within safety boundaries (1.48M in [1.0M, 2.0M]).\nSELECT COUNT(*) AS total_rows FROM production_analytics.dim_users;`, anomalies: [], }, { id: 'dq-assert-5', assertionType: 'expect_column_values_to_be_between', columnName: 'age', category: 'Validity', ruleDefinition: 'Demographic account age boundary distribution constraint between 18 and 120 years.', targetThreshold: '100.0%', observedValue: '100.0%', observedPercent: 100.0, failedCount: 0, totalEvaluated: 1480000, status: 'Passing', statusVariant: 'success', executionTime: '210ms', expectationConfig: { expectation_type: 'expect_column_values_to_be_between', kwargs: { column: 'age', min_value: 18, max_value: 120, mostly: 1.0, }, }, remediationQuery: `-- All verified user ages lie cleanly between min 18 and max 94 (100.0% compliant).\nSELECT MIN(age), MAX(age), AVG(age) FROM production_analytics.dim_users;`, anomalies: [], }, ] export function DataQualityMetrics({ datasetTitle = 'production_analytics.dim_users', suiteName = 'user_profile_integrity_v3', qualityScore = 98.4, lastRun = 'Ran 14m ago · 48 assertions evaluated', passedAssertions = '47 / 48 Passing · 98%', failedWarnings = '1 Warning · Null phone numbers 1.2%', schemaDriftStatus = '0 breaking schema changes', totalRowsAudited = '1,480,000 rows', assertions = defaultAssertions, className, }: DataQualityMetricsProps) { const [searchQuery, setSearchQuery] = React.useState('') const [selectedStatus, setSelectedStatus] = React.useState('all') const [selectedCategory, setSelectedCategory] = React.useState('all') const [isRunningSuite, setIsRunningSuite] = React.useState(false) const [currentLastRun, setCurrentLastRun] = React.useState(lastRun) const [selectedAssertion, setSelectedAssertion] = React.useState(null) const [isDrawerOpen, setIsDrawerOpen] = React.useState(false) const [copiedSnippetKey, setCopiedSnippetKey] = React.useState(null) const [exportSuccess, setExportSuccess] = React.useState(false) const [anomalyExportSuccess, setAnomalyExportSuccess] = React.useState(false) const availableCategories = React.useMemo(() => { const categories = new Set() assertions.forEach((item) => categories.add(item.category)) return ['all', ...Array.from(categories)] }, [assertions]) const filteredAssertions = React.useMemo(() => { const query = searchQuery.trim().toLowerCase() const statusFilter = selectedStatus const categoryFilter = selectedCategory return assertions.filter((item) => { const matchesStatus = statusFilter === 'all' || item.status.toLowerCase() === statusFilter.toLowerCase() const matchesCategory = categoryFilter === 'all' || item.category.toLowerCase() === categoryFilter.toLowerCase() const matchesQuery = !query || item.assertionType.toLowerCase().includes(query) || item.columnName.toLowerCase().includes(query) || item.ruleDefinition.toLowerCase().includes(query) || item.category.toLowerCase().includes(query) return matchesStatus && matchesCategory && matchesQuery }) }, [assertions, searchQuery, selectedStatus, selectedCategory]) const handleRunSuite = React.useCallback(() => { if (isRunningSuite) return setIsRunningSuite(true) setTimeout(() => { setIsRunningSuite(false) setCurrentLastRun('Ran just now · 48 assertions evaluated') }, 750) }, [isRunningSuite]) const handleInspectAnomalies = React.useCallback((assertion: AssertionItem) => { setSelectedAssertion(assertion) setIsDrawerOpen(true) }, []) const copyCodeSnippet = React.useCallback((key: string, content: string) => { if (typeof navigator !== 'undefined' && navigator.clipboard) { navigator.clipboard.writeText(content) setCopiedSnippetKey(key) setTimeout(() => { setCopiedSnippetKey((curr) => (curr === key ? null : curr)) }, 2000) } }, []) const exportQualityReport = React.useCallback(() => { const report = { dataset: datasetTitle, suite: suiteName, overallQualityScore: qualityScore, evaluatedAt: new Date().toISOString(), engine: 'Great Expectations v0.18 / SodaCL', summary: { passed: passedAssertions, warnings: failedWarnings, schemaDrift: schemaDriftStatus, totalRows: totalRowsAudited, }, assertions, } const jsonStr = 'data:text/json;charset=utf-8,' + encodeURIComponent(JSON.stringify(report, null, 2)) if (typeof document !== 'undefined') { const link = document.createElement('a') link.setAttribute('href', jsonStr) link.setAttribute('download', `dq-report-${suiteName}-${new Date().toISOString().slice(0, 10)}.json`) document.body.appendChild(link) link.click() link.remove() setExportSuccess(true) setTimeout(() => { setExportSuccess(false) }, 2000) } }, [ datasetTitle, suiteName, qualityScore, passedAssertions, failedWarnings, schemaDriftStatus, totalRowsAudited, assertions, ]) const exportAnomalyCsv = React.useCallback(() => { if (!selectedAssertion || selectedAssertion.anomalies.length === 0) return const headers = ['Record ID', 'Column', 'Observed Value', 'Failure Reason'] const rows = selectedAssertion.anomalies.map((a) => [a.recordId, a.column, `"${a.value}"`, `"${a.reason}"`]) const csvContent = [headers.join(','), ...rows.map((r) => r.join(','))].join('\n') const blob = new Blob([csvContent], { type: 'text/csv;charset=utf-8;' }) const url = URL.createObjectURL(blob) const link = document.createElement('a') link.setAttribute('href', url) link.setAttribute('download', `anomalies-${selectedAssertion.columnName}.csv`) document.body.appendChild(link) link.click() link.remove() setAnomalyExportSuccess(true) setTimeout(() => { setAnomalyExportSuccess(false) }, 2000) }, [selectedAssertion]) return (

{/* Header Section */}

{/* Left: Dataset and Suite Metadata */}

{datasetTitle}

{suiteName}

{currentLastRun} · Snowflake DW · dbt Core v1.8

{/* Right: Overall Score Card & Action Buttons */}

{/* Overall Score Pill Card */}

{qualityScore}% Quality Score

Automated Sodacl / GX Engine

{/* Action Buttons */}

{/* Sub-bar Contract Guarantee */}

Schema Contract: Locked v3.2 · Zero Breaking Schema Drift

Engine SLA: Strict Production 48 assertions evaluated

{/* 4 Assertion Metric Cards */}

{/* Card 1: Passed Assertions */}

Passed Assertions

47 / 48 98% Passing

{passedAssertions}

{/* Card 2: Failed / Warnings */}

Failed / Warnings

1 Warning 1.2% Non-conformant

{failedWarnings}

{/* Card 3: Schema Drift Status */}

Schema Drift Status

0 Breaking No Drift

Columns Synced 14 / 14 matched

{schemaDriftStatus}

{/* Card 4: Total Rows Audited */}

Total Rows Audited

1,480,000 1.48M Rows

Partition Range 1.0M .. 2.0M

{totalRowsAudited}

{/* Data Quality Test Assertions Table Card */}

Data Quality Test Assertions {filteredAssertions.length} of {assertions.length} Assertions

Automated expectations, boundary validations, regex format rules, and volume anomaly checks.

{/* Filter Pills by Status */}

{/* Filter & Search Toolbar */}

setSearchQuery(e.target.value)} type="text" placeholder="Search by assertion type, column name, or rule definition..." className="border-border bg-background placeholder:text-muted-foreground focus-visible:ring-ring h-8 w-full rounded-md border px-3 pl-8 text-xs focus-visible:ring-2 focus-visible:outline-none" />

Category: {availableCategories.map((cat) => ( ))}

{/* Table Container */}

Assertion & Target Column Category Target Threshold Observed Value Status Actions {filteredAssertions.map((assertion) => ( {/* Assertion Type & Target Column */}

{assertion.columnName} {assertion.assertionType}

{assertion.ruleDefinition}

{/* Category */} {assertion.category} {/* Target Threshold */} {assertion.targetThreshold} {/* Observed Value */}

{assertion.observedValue} {assertion.executionTime} eval

{/* Status Badge */} {assertion.status === 'Passing' ? ( ) : assertion.status === 'Warning' ? ( ) : ( )} {assertion.status} {/* Action Button */} ))} {filteredAssertions.length === 0 && (

No assertions match your filter query

All assertions meet standard quality constraints.

)}

{/* Table Footer */}

Great Expectations Assertions Runner: 100% evaluated

Dataset: {datasetTitle} · Last Batch: 1,480,000 rows

{/* Anomaly Inspector Drawer / Sheet */} {selectedAssertion && ( <>

{selectedAssertion.status === 'Passing' ? ( ) : ( )} {selectedAssertion.status.toUpperCase()} {selectedAssertion.category}

Latency: {selectedAssertion.executionTime}

{selectedAssertion.assertionType} Target Column:{' '} {selectedAssertion.columnName}

{/* Summary Metrics Cards Grid */}

Target Threshold

{selectedAssertion.targetThreshold}

Observed Pass Rate

{selectedAssertion.observedValue}

Audited Records

{selectedAssertion.totalEvaluated.toLocaleString()}

Failed Anomalies

0 ? 'text-warning' : 'text-success', )} > {selectedAssertion.failedCount.toLocaleString()}

{/* Expectation Configuration DSL Box */}

Great Expectations Specification

expectation_suite.json

                      {JSON.stringify(selectedAssertion.expectationConfig, null, 2)}

{/* Anomalous Samples Table or Clean Pass State */}

Anomalous Sample Records

{selectedAssertion.anomalies.length > 0 && ( Showing {selectedAssertion.anomalies.length} failure samples )}

{selectedAssertion.anomalies.length > 0 ? (

Record ID Column Observed Value Diagnostic Reason {selectedAssertion.anomalies.map((anomaly) => ( {anomaly.recordId} {anomaly.column} {anomaly.value} {anomaly.reason} ))}

) : (

Zero Anomalies Detected

All {selectedAssertion.totalEvaluated.toLocaleString()} audited records strictly satisfied the expectation rule.

)}

{/* Quarantine SQL Script */}

Quarantine & Remediation SQL

                      {selectedAssertion.remediationQuery}

{selectedAssertion.anomalies.length > 0 && ( )} )}

) } 61:["$","div",null,{"className":"mt-3 flex min-h-0 min-w-0 flex-1 flex-col gap-3","children":[["$","div",null,{"className":"flex shrink-0 items-start gap-3","children":[["$","div",null,{"className":"flex max-h-28 min-w-0 flex-1 flex-wrap items-center gap-2 overflow-y-auto","children":[["$","ul",null,{"className":"flex min-w-0 flex-wrap gap-2","aria-label":"Package dependencies","children":[["$","li","lucide-react",{"className":"min-w-0 max-w-full","children":["$","a",null,{"href":"https://www.npmjs.com/package/lucide-react","target":"_blank","rel":"noopener noreferrer","className":"flex max-w-full min-w-0 items-center gap-1.5 rounded-md border px-2 py-1.5 text-xs","children":[["$","svg",null,{"viewBox":"0 0 24 24","className":"size-3 shrink-0","children":["$","path",null,{"d":"M1.763 0C.786 0 0 .786 0 1.763v20.474C0 23.214.786 24 1.763 24h20.474c.977 0 1.763-.786 1.763-1.763V1.763C24 .786 23.214 0 22.237 0zM5.13 5.323l13.837.019-.009 13.836h-3.464l.01-10.382h-3.456L12.04 19.17H5.113z","fill":"currentColor"}]}],["$","span",null,{"className":"min-w-0 break-all text-xs font-medium","children":"lucide-react"}]]}]}]]}],["$","$L62",null,{"namespace":"@registrydirectory","registryDependencies":["https://uipkge.dev/r/react/badge.json","https://uipkge.dev/r/react/button.json","https://uipkge.dev/r/react/card.json","https://uipkge.dev/r/react/progress.json","https://uipkge.dev/r/react/separator.json","https://uipkge.dev/r/react/sheet.json","https://uipkge.dev/r/react/table.json"]}]]}],null]}],["$","$L63",null,{"files":[{"path":"packages/registry-react/blocks/data-quality-metrics/DataQualityMetrics.tsx","content":"$64","type":"registry:block","target":"~/components/blocks/DataQualityMetrics.tsx"}],"className":"h-[70svh] min-h-80"}]]}]