Level 8 - PrincipalQuery-Based Questionsm4 streaming cdc events
Ingestion Lag by Pipeline
Return pipeline lag in minutes using max event_ts over last 10 minutes of ingests.
Schema Context
ingestion_events(pipeline_id, event_id, event_ts, ingested_at)