Fixing logic error in submission batches

2022-02-01 13:34:19 -04:00
parent df108dfd28
commit b3397381dc
1 changed files with 3 additions and 1 deletions
--- a/libdaggy/src/DAGRunner.cpp
+++ b/libdaggy/src/DAGRunner.cpp
@@ -110,6 +110,8 @@ namespace daggy {

    while (n_submitted < MAX_SUBMITS) {
      auto t = dag_.visitNext();
+      if (!t)
+        continue;
      auto &taskName               = t.value().first;
      taskAttemptCounts_[taskName] = 1;