Only consider 50 tasks when managing the task graph

This commit is contained in:
Matthew Jones 2015-01-06 10:12:12 -05:00
parent 6fccee404a
commit a53071ff07

View File

@ -233,7 +233,7 @@ def rebuild_graph(message):
graph = SimpleDAG()
for task in running_tasks:
graph.add_node(task)
for wait_task in waiting_tasks[:500]:
for wait_task in waiting_tasks[:50]:
node_dependencies = []
for node in graph:
if wait_task.is_blocked_by(node['node_object']):