Graph Scheduler Task

[johanhenriksson]

Implementation of a DAG scheduler as a Cowait task.

Example:

from cowait.tasks.graph import GraphTask
from sleep import Sleep

class GraphExample(GraphTask):
    async def define(self, graph, **inputs):
        a = graph.node(Sleep, {
            'duration': 3,
        })
        b = graph.node(Sleep, {
            'duration': 5,
        })
        graph.node(Sleep, {
            'a': a.output('duration'),
            'b': b.output('duration'),
        })

[OskarHandmark]

👍

[OskarHandmark]

Allow export of the graph (to json?) in/after define()? Would play nicely in a UI, especially with live updates. Show the graph in terminal before running? :)

[OskarHandmark]

Before we run this we should make sure it has no loops

[johanhenriksson]

a validation step sounds like a pretty good idea 😬