* Destroy all active pipelines. Called on graceful server shutdown.
()
| 576 | /** Close all runtime driver sessions during graceful server shutdown. */ |
| 577 | async destroyAll(): Promise<void> { |
| 578 | await this.runtimeCoordinator.destroyAll(); |
| 579 | await Promise.allSettled(this.externalSessionPersistence.values()); |
| 580 | this.externalSessionPersistence.clear(); |
| 581 | this.terminalSessions.clear(); |
| 582 | for (const resolve of this.pendingAutoCommitResolvers.values()) resolve(); |
| 583 | this.pendingAutoCommitResolvers.clear(); |
| 584 | this.pendingAutoCommits.clear(); |
| 585 | for (const release of [...this.followUpReservationReleases]) release(); |
| 586 | this.followUpReservationReleases.clear(); |
| 587 | this.followUpReservations.clear(); |
| 588 | clearAgentApiCredentials(); |
| 589 | } |
| 590 | |
| 591 | private resolveAgentSessionId(sessionId: string, logSnapshot: string | null): string | null { |
| 592 | const msgStore = sessionMsgStoreManager.get(sessionId); |
| 593 | if (msgStore) { |
no test coverage detected