Completed some pending to-do's (minor improvements).

src/engine/flow.ts

@@ -145,8 +145,8 @@ export class Flow {
   }
 
   protected setExpectedResults(expectedResults: string[] = []) {
+
     // Check expected results that cannot be fulfilled
-    // @todo make this configurable (throw or not throw an error)
     const missingExpected = expectedResults.filter(r => !this.taskProvisions.includes(r));
     if (missingExpected.length > 0) {
       const msg = `Warning: The results [${missingExpected.join(', ')}] are not provided by any task`;
@@ -209,8 +209,6 @@ export class Flow {
   }
 
   protected initRunStatus() {
-    // @todo Avoid initializing twice.
-
     this.state = FlowReady.getInstance();
 
     this.runStatus = new FlowRunStatus();

src/engine/task-types.ts

@@ -1,4 +1,3 @@
-// @todo Check if this is needed
 import { Task } from './task';
 
 export interface TaskMap {
@@ -12,9 +11,6 @@ export interface TaskRunStatus {
     [name: string]: any;
   };
 
-  // @todo Check if this is needed
-  pendingResults: string[];
-
   solvedResults: {
     [name: string]: any;
   };

src/engine/task.ts

@@ -7,17 +7,11 @@ export class Task {
 
   protected spec: TaskSpec;
 
-  protected runStatus: TaskRunStatus;
+  protected runStatus!: TaskRunStatus;
 
   public constructor(code: string, spec: TaskSpec) {
     this.code = code;
     this.spec = spec;
-    this.runStatus = {
-      pendingReqs: [],
-      solvedReqs: {},
-      pendingResults: [],
-      solvedResults: {},
-    };
 
     this.parseSpec();
   }
@@ -35,11 +29,9 @@ export class Task {
   }
 
   public resetRunStatus() {
-    // @todo Avoid initializing twice.
     this.runStatus = {
       pendingReqs: [...this.spec.requires],
       solvedReqs: {},
-      pendingResults: [...this.spec.provides],
       solvedResults: {},
     };
   }