DAG-based integration test framework with durable state.
pip install dagtestfrom dagtest import test
@test
async def test_root(ctx):
return {"value": 1}
@test(depends_on=["test_root"])
async def test_child(ctx):
parent_value = ctx.results["test_root"]["value"]
assert parent_value == 1
return {"computed": parent_value + 1}dagtest run
dagtest list
dagtest graphMIT