environment/share/doc/ipython/examples/parallel/dagdeps.py
def validate_tree(G, results):
    """Validate that jobs executed after their dependencies."""
    for node in G:
        started = results[node].metadata.started
        for parent in G.predecessors(node):
            finished = results[parent].metadata.completed
            assert started > finished, "%s should have happened after %s"%(node, parent)
def validate_tree(G, results):
    for node in G:
        started = results[node].metadata.started
        for parent in G.predecessors(node):
            finished = results[parent].metadata.completed
            assert started > finished, "%s should have happened after %s"%(node, parent)
def validate_tree ( G , results ) : for node in G : started = results [ node ] . metadata . started for parent in G . predecessors ( node ) : finished = results [ parent ] . metadata . completed assert started > finished , "%s should have happened after %s" % ( node , parent )
Validate that jobs executed after their dependencies.
Validate that jobs executed after their dependencies .