That's the kind of stuff Prismatic is making available in the Graph extension to their plumbing package (code examples), which is described in an excellent post: Graph: Abstractions for Structured Computation. You may …
Link:
When all the Program's a Graph – Prismatic's … – High Scalability