(live: LiveShellRun)
| 966 | } |
| 967 | |
| 968 | private async markRunning(live: LiveShellRun): Promise<void> { |
| 969 | live.record = await this.input.store.updateShellRun(live.sessionId, live.shellRunId, { |
| 970 | status: 'running', |
| 971 | output: (await this.snapshotAtCut(live, false)).output, |
| 972 | updatedAt: this.input.now(), |
| 973 | }); |
| 974 | if (live.driverExit) { |
| 975 | void this.beginFinalize(live).catch(() => {}); |
| 976 | } else if (this.currentGeneration(live) > 0) { |
| 977 | this.scheduleAutomaticFlush(live); |
| 978 | } |
| 979 | } |
| 980 | |
| 981 | private onPipeData(live: LivePipeShellRun, stream: 'stdout' | 'stderr', data: string): void { |
| 982 | if (live.driverExit || live.finalizeOnce) return; |
no test coverage detected