For knowledge document of this organization, you can follow this like Document.
flowchart LR
1([ddeutil]) --> 2([ddeutil-io]) --> 3([🏃 ddeutil-workflow]) --> 4([📡 ddeutil-observe])
1 --> 4
2 --> 5([ddeutil-vendors])
0([fmtutil]) -.-> 2
0 -.-> 5
This organization has the propose to make lightweight data orchestration framework for small to middle project scale (1-1000 workflows).
Firstly, I will implement base projects, Core (utility functions) and IO (Input/Output transport utility objects) for the first dependency packages because it has a lot of base code to make main package and I do not want to develop this code on the main package, for example, it do not good if I want fix bug on the merge key function that no relate with the workflow package
🎯 The main package of this organize orchestration framework has 2 layers and I split it with 2 projects for optional installation requirement (you can only use just one of these layers without raise error).
- 🏃 Workflow - Lightweight workflow orchestration in Python with less dependencies.
- 📡 Observe - Lightweight observation application with FastAPI for the workflow package.
Note
I have some 3rd-party projects, Vendors, for keeping
an additional practices to use any 3rd API connect data source, like polars
, duckdb
, etc.
It be dynamic data processing & transformation objects from external vendor packages.
This organize has some mini-projects that develop for specific usecase:
- ddeapp-flask - Full-Stack Data Orchestration from Yaml template with Flask & HTMX
- ddeapp-fastapi - Routing Application Service deploy to On-Premise server with FastAPI
Warning
The above projects have a lot of bugs and need time to fix and refactored the code.