Repository navigation
v0.0.7
🚀 Release 0.0.7 — Key Features
-
Result[T, E]Monad- Rust‑style
Ok/Errwrapper for sync & async flows - Methods:
map,and_then,unwrap_or,match, plus*_asyncvariants - JSON/
dictserialization, customUnwrapError
- Rust‑style
-
Sync Task System
BaseSyncTaskabstract base: retry logic + exponential backoff +task_id/task_name+ loggingFunctionSyncTaskdecorator fordef f(res: Result)->ResultfunctionsClassSyncTasksubclassable for stateful logic inexecute(res: Result)->Result
-
Async Task System
- Mirror of sync tasks under
BaseAsyncTask FunctionAsyncTaskforasync def f(res: Result)->Resultwith retriesClassAsyncTaskfor complex async workflows
- Mirror of sync tasks under
-
Sync Pipeline
SyncPipeline: sequential chaining ofResult‑driven tasks- One‑to‑one parallel helper
run_parallel()for running multiple pipelines concurrently and merging outputs debugmode: returns full ordered trace of(task_name, Result)
-
Async Pipeline
AsyncPipeline: concurrent execution ofBaseAsyncTasklist, one input per taskdebugmode support for per‑task trace capture
-
Validation & Safety
- Signature checks on every task’s
execute(...)to enforceResult‑based input - Runtime type checks to catch input/output mismatches early
- Comprehensive unit tests covering happy paths, error short‑circuit, retry, debug traces, and invalid configurations
- Signature checks on every task’s
-
Documentation & Examples
- Full MkDocs site with:
task_sync.md/task_async.mdreference pagesbasic_usage_task.md,pipeline_basics.md,basic_usage_async_pipeline.mdexamples- Quick‑start “run locally” guide
- Code snippets for real‑world scenarios (OpenAI, data filtering, I/O mocks)
- Full MkDocs site with: