MCPcopy
hub / github.com/triggerdotdev/trigger.dev / _doHeartbeat

Function _doHeartbeat

packages/cli-v3/src/workers/dev/worker-facade.ts:228–240  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

226
227async 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));

Callers 1

asyncHeartbeatFunction · 0.70

Calls 2

sendMethod · 0.65
errorMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…