DEBUG

Author: ahal

src/taskgraph/create.py

@@ -82,23 +82,36 @@ def submit(task_id, label, task_def):
                 fs_to_task[fut] = (task_id, label)
 
             for task_id in tasklist:
+
+                def dump(msg):
+                    if taskid_to_label[task_id] == "complete-pr":
+                        print(msg)
+
+                dump("NEW ITERATION")
+
                 task_def = taskgraph.tasks[task_id].task
                 # Some dependencies aren't in our graph, so make sure to filter
                 # those out
                 deps = set(task_def.get("dependencies", [])) & alltasks
+                dump(deps)
+                dump("skipped:")
+                dump(skipped)
 
                 # If one of the dependencies didn't get created, then
                 # don't attempt to submit as it would fail.
                 if any(d in skipped for d in deps):
+                    dump("skipping complete-pr YAY")
                     skipped.add(task_id)
                     to_remove.add(task_id)
                     continue
 
                 # If we haven't finished submitting all our dependencies yet,
                 # come back to this later.
                 if any((d not in fs or not fs[d].done()) for d in deps):
+                    dump("nooooot done")
                     continue
 
+                dump("submitting :(")
                 submit(task_id, taskid_to_label[task_id], task_def)
                 to_remove.add(task_id)