()
| 110 | } |
| 111 | |
| 112 | public execute(): this { |
| 113 | if (!!this.executionTask) { |
| 114 | throw new Error("Executor already started."); |
| 115 | } |
| 116 | this.executionTask = this.executeGraph(); |
| 117 | if (!!this.graph.runConfig && !!this.graph.runConfig.timeoutMillis) { |
| 118 | const now = Date.now(); |
| 119 | const runStartMillis = this.runResult.timing?.startTimeMillis?.toNumber?.() || now; |
| 120 | const elapsedTimeMillis = now - runStartMillis; |
| 121 | const timeoutMillis = this.graph.runConfig.timeoutMillis - elapsedTimeMillis; |
| 122 | this.timeout = setTimeout(() => { |
| 123 | this.timedOut = true; |
| 124 | this.cancel(); |
| 125 | }, timeoutMillis); |
| 126 | } |
| 127 | return this; |
| 128 | } |
| 129 | |
| 130 | public stop() { |
| 131 | this.stopped = true; |
nothing calls this directly
no test coverage detected