Architecture
Layers
graph TB
A[Dagster Orchestration] --> B[Cockpit Core]
B --> C[Operators]
B --> D[Resources]
C --> E[Polars + Delta Lake]
D --> E
E --> F[MinIO Storage]
Components
| Module |
Role |
core/ |
Pipeline and asset definitions |
operators/ |
Data transformation operators |
resources/ |
External resources (Delta Lake, MinIO) |
Data Flow
- Dagster orchestrates pipelines defined in Cockpit
- Pandera validates DataFrames against contracts
- Polars processes data efficiently
- Delta Lake provides ACID storage with time travel