()
| 226 | |
| 227 | async function asyncHeartbeat(initialDelayInSeconds: number = 30, intervalInSeconds: number = 30) { |
| 228 | async function _doHeartbeat() { |
| 229 | while (true) { |
| 230 | if (_isRunning && _execution) { |
| 231 | try { |
| 232 | await sender.send("TASK_HEARTBEAT", { id: _execution.attempt.id }); |
| 233 | } catch (err) { |
| 234 | console.error("Failed to send HEARTBEAT message", err); |
| 235 | } |
| 236 | } |
| 237 | |
| 238 | await new Promise((resolve) => setTimeout(resolve, 1000 * intervalInSeconds)); |
| 239 | } |
| 240 | } |
| 241 | |
| 242 | // Wait for the initial delay |
| 243 | await new Promise((resolve) => setTimeout(resolve, 1000 * initialDelayInSeconds)); |
no test coverage detected
searching dependent graphs…