Workflow engine core with Starlark-subset parser, DAG execution, and cache planning primitives.
import {
"mizchi/bitflow/workflow" @wf,
}
let nodes = [@wf.new_node("root", []), @wf.new_node("dep", ["root"])]
let tasks = [
@wf.new_task("root:build", "root", "build", []),
@wf.new_task("dep:test", "dep", "test", ["root:build"]),
]
let ir = @wf.new_ir("ci", nodes, tasks, entry_targets=["dep:test"])
let result = @wf.execute_ir(ir, fn(_task : @wf.FlowTask) { (true, "") })
inspect(result.ok, content="true")fn fib(n : Int) -> Int64test {
inspect(fib(10), content="89")
}Install
Download zipWorkflow engine core with Starlark-subset parser, DAG execution, and cache planning primitives.