| ID | product.processing |
|---|---|
| Description | Batch and streaming transformations orchestrated end-to-end. |
| Key | processing |
| Type | system |
| Team | Data Engineering |
| Owner | eng@dataplatform.example |
| Status | active |
| Technologies | Spark, dbt, Airflow |
| Attributes | modes: batch,stream, orchestration: dag |
| Tags |
Processing is where raw data becomes trustworthy. It runs the orchestrated batch DAGs that refresh gold warehouse tables every night, and the stateful streaming jobs that power live dashboards — always with validation gates that block corrupt data from propagating downstream.
Responsibility in one sentence
Schedule and execute batch and streaming transformations, validate outputs, emit lineage, and halt dependent work when quality rules fail.
Could not build diagram for model "example-data-processing".
The nightly refresh is owned end-to-end by batch processing:
Real-time aggregates for dashboards flow through the stream pipeline:
Quality gates
When the Data Validator fails a test, the orchestrator blocks downstream tasks — the batch path stops before gold tables are corrupted.
2 incoming links · 2 outgoing links
| Source object | Label | Link type | Relation | Raw id | Required | Description | |
|---|---|---|---|---|---|---|---|
| builds pipelines in | — | links | product.processing | — | — | ||
| feeds | — | links | product.processing | — | — |
| Target object | Label | Link type | Relation | Raw id | Required | Description | |
|---|---|---|---|---|---|---|---|
| publishes results to | — | links | product.serving | — | — | ||
| reports lineage to | — | links | product.governance | — | — |