update

twosigma · Mar 8, 2021 · 4a1ec8e · 4a1ec8e
1 parent 915c633
commit 4a1ec8e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/uberjob/_execution/run_function_on_graph.py b/src/uberjob/_execution/run_function_on_graph.py
@@ -128,7 +128,7 @@ def run_function_on_graph(
     error_count = 0
     failure_lock = threading.Lock()
 
-    queue = create_queue(graph, source_nodes(graph), scheduler)
+    queue = create_queue(graph, source_nodes, scheduler)
 
     def process_node(node):
         nonlocal stop