MCPcopy Create free account
hub / github.com/apache/maka / markRunning

Method markRunning

packages/runtime/src/shell-run-manager.ts:968–979  ·  view source on GitHub ↗
(live: LiveShellRun)

Source from the content-addressed store, hash-verified

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;

Callers 2

startPipeMethod · 0.95
startPtyMethod · 0.95

Calls 6

snapshotAtCutMethod · 0.95
beginFinalizeMethod · 0.95
currentGenerationMethod · 0.95
updateShellRunMethod · 0.65
nowMethod · 0.65

Tested by

no test coverage detected