Send a heartbeat via POST /sessions/{id}/worker/heartbeat.
()
| 704 | |
| 705 | /** Send a heartbeat via POST /sessions/{id}/worker/heartbeat. */ |
| 706 | private async sendHeartbeat(): Promise<void> { |
| 707 | if (this.heartbeatInFlight) return |
| 708 | this.heartbeatInFlight = true |
| 709 | try { |
| 710 | const result = await this.request( |
| 711 | 'post', |
| 712 | '/worker/heartbeat', |
| 713 | { session_id: this.sessionId, worker_epoch: this.workerEpoch }, |
| 714 | 'Heartbeat', |
| 715 | { timeout: 5_000 }, |
| 716 | ) |
| 717 | if (result.ok) { |
| 718 | logForDebugging('CCRClient: Heartbeat sent') |
| 719 | } |
| 720 | } finally { |
| 721 | this.heartbeatInFlight = false |
| 722 | } |
| 723 | } |
| 724 | |
| 725 | /** |
| 726 | * Write a StdoutMessage as a client event via POST /sessions/{id}/worker/events. |
no test coverage detected