environment/share/doc/ipython/examples/parallel/dagdeps.py
def submit_jobs(view, G, jobs):
    """Submit jobs via client where G describes the time dependencies."""
    results = {}
    for node in nx.topological_sort(G):
        with view.temp_flags(after=[ results[n] for n in G.predecessors(node) ]):
            results[node] = view.apply(jobs[node])
    return results
def submit_jobs(view, G, jobs):
    results = {}
    for node in nx.topological_sort(G):
        with view.temp_flags(after=[ results[n] for n in G.predecessors(node) ]):
            results[node] = view.apply(jobs[node])
    return results
def submit_jobs ( view , G , jobs ) : results = { } for node in nx . topological_sort ( G ) : with view . temp_flags ( after = [ results [ n ] for n in G . predecessors ( node ) ] ) : results [ node ] = view . apply ( jobs [ node ] ) return results
Submit jobs via client where G describes the time dependencies.
Submit jobs via client where G describes the time dependencies .