Skip to content

Commit 13afaa2

Browse files
committed
add resource monitor example
1 parent 3aeb86b commit 13afaa2

File tree

1 file changed

+26
-0
lines changed

1 file changed

+26
-0
lines changed

references/hello-world/src/trigger/example.ts

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import { batch, logger, task, timeout, wait } from "@trigger.dev/sdk";
22
import { setTimeout } from "timers/promises";
3+
import { ResourceMonitor } from "../resourceMonitor.js";
34

45
export const helloWorldTask = task({
56
id: "hello-world",
@@ -206,3 +207,28 @@ export const hooksTask = task({
206207
logger.info("Hello, world from the cleanup hook", { payload });
207208
},
208209
});
210+
211+
export const resourceMonitorTest = task({
212+
id: "resource-monitor-test",
213+
run: async (payload: { dirName?: string; processName?: string }, { ctx }) => {
214+
logger.info("Hello, resources!", { payload });
215+
216+
const resMon = new ResourceMonitor({
217+
ctx,
218+
dirName: payload.dirName ?? "/tmp",
219+
processName: payload.processName ?? "node",
220+
});
221+
222+
resMon.startMonitoring(1_000);
223+
224+
resMon.logResourceSnapshot();
225+
226+
await wait.for({ seconds: 5 });
227+
228+
resMon.logResourceSnapshot();
229+
230+
return {
231+
message: "Hello, resources!",
232+
};
233+
},
234+
});

0 commit comments

Comments
 (0)