Show More
@@ -123,7 +123,7 b' on which it depends:' | |||||
123 | ...: deps = [ results[n] for n in G.predecessors(node) ] |
|
123 | ...: deps = [ results[n] for n in G.predecessors(node) ] | |
124 | ...: # submit and store AsyncResult object |
|
124 | ...: # submit and store AsyncResult object | |
125 | ...: with view.temp_flags(after=deps, block=False): |
|
125 | ...: with view.temp_flags(after=deps, block=False): | |
126 |
...: results[node] = view.apply |
|
126 | ...: results[node] = view.apply(jobs[node]) | |
127 |
|
127 | |||
128 |
|
128 | |||
129 | Now that we have submitted all the jobs, we can wait for the results: |
|
129 | Now that we have submitted all the jobs, we can wait for the results: |
General Comments 0
You need to be logged in to leave comments.
Login now