test.py: Fix in CommandQueue to make sure we finish up correctly if an intermediate command failed

tools/testing/dart/test_runner.dart

Index: tools/testing/dart/test_runner.dart
diff --git a/tools/testing/dart/test_runner.dart b/tools/testing/dart/test_runner.dart
index e09d153bf2e98ad1791f394863e4b35901301f66..dd0f2f0de40a177cd7eebd65dfaaa593eced3b7d 100644
--- a/tools/testing/dart/test_runner.dart
+++ b/tools/testing/dart/test_runner.dart
@@ -1573,8 +1573,6 @@ class CommandEnqueuer {
   }
 }
 
-// TODO(kustermann): Add support for '--list' and '--verbose'!
-
 /*
  * [CommandQueue] will listen for nodes entering the NodeState.ENQUEUING state,
  * queue them up and run them. While nodes are processed they will be in the
@@ -1622,8 +1620,18 @@ class CommandQueue {
             Timer.run(() => _tryRunNextCommand());
           }
     });
-    eventCondition((event) => event is dgraph.GraphSealedEvent).listen((_) {
-      _checkDone();
+    // We're finished if the graph is sealed and all nodes are in a finished
+    // state (Successfull, Failed or UnableToRun).
+    // So we're calling '_checkDone()' to check whether that condition is met
+    // and we can cleanup.
+    graph.events.listen((dgraph.GraphEvent event) {
+      if (event is dgraph.GraphSealedEvent) {
+        _checkDone();
+      } else if (event is dgraph.StateChangedEvent) {
+        if (event.to == dgraph.NodeState.UnableToRun) {
+          _checkDone();
+        }
+      }
     });
   }
 
@@ -1979,7 +1987,6 @@ class TestCaseCompleter {
 }
 
 
-
 class ProcessQueue {
   Map _globalConfiguration;