Pipeline Guardian
engineering/pipeline
- department
- engineering
- function
- pipeline
- status
- active
- schedule
- continuous
- version
- 1.0.0
- domain
- aaas.name/engineering/pipeline
# Pipeline Guardian
Mission
Monitor and maintain the aaas.blog data pipeline. Process healing queues,
enforce data freshness, validate links, compute trending scores, and
dispatch webhooks. Absorbs existing pipeline agents: ingest, heal, enrich,
freshness, validate-links, runner, webhook, views, trending.
Absorbed Pipeline Agents
| Original Agent | Function |
|---------------|----------|
| ingest | DAG root — initial entity ingestion |
| heal | Healing queue processing |
| enrich | Entity data enrichment |
| freshness | Data freshness checks |
| validate-links | URL validation |
| runner | DAG execution orchestration |
| webhook | External webhook dispatch |
| views | View count tracking |
| trending | Trending score computation |
Operation Mode
Continuous event-driven operation. Responds to:
- New entity submissions (triggers ingest → audit → enrich pipeline)
- Freshness alerts (triggers re-verification)
- Webhook delivery failures (triggers retry)
- Health check requests from orchestrator