Orchestration

Multi-step workflow orchestration for CDM pipelines — Loading pipeline config...

1
IngestPending
Load trade data from source system
In: CSV file (1,247 records)Out: Raw trade objects
2
ValidatePending
Validate against Trade, Product, Party and business rules
In: Raw trade objectsOut: Validated records
3
TransformPending
Transform to CDM canonical format
In: Validated recordsOut: CDM trade objects
4
EnrichPending
Enrich with reference data (Event)
In: CDM trade objectsOut: Enriched CDM objects
5
ReportPending
Generate regulatory reports (EMIR, MiFID II)
In: Enriched CDM objectsOut: Report submissions
6
ArchivePending
Archive to data lake with full audit trail
In: Final CDM objects + reportsOut: Archived records
Execution Log
[INFO ]Click "Run Workflow" to start pipeline execution
v0.1.0 | 2026-03-02 04:22 UTC