test: wait for trigger to fire

allanhvam · Dec 6, 2024 · 96268b3 · 96268b3
1 parent 2c7889d
commit 96268b3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/tests/triggers.test.ts b/src/tests/triggers.test.ts
@@ -3,6 +3,7 @@ import assert from "node:assert";
 import { Worker } from "../worker/Worker.js";
 import { DurableFunctionsWorkflowHistoryStore } from "../stores/index.js";
 import { startup } from "./workflows/startup.js";
+import { sleep } from "../sleep.js";
 
 test.before(async () => {
     const worker = Worker.getInstance();
@@ -36,6 +37,7 @@ void test("startup trigger args", async (t) => {
 
     // Act
     await workflow.start();
+    await sleep("1s"); // Wait for trigger to fire
 
     // Assert
     const result = await store.getInstances();

diff --git a/src/tests/workflows.test.ts b/src/tests/workflows.test.ts
@@ -41,12 +41,12 @@ void test("Workflow", async (t) => {
 
     // Assert
     assert.equal(result, 3);
-    assert.ok(workflows.has("math"));
+    assert.ok(workflows.has(workflow.name));
 
     const now = new Date();
     const from = new Date(now.getTime() - ms("2m"));
     const instances = await store.getInstances({ filter: { from, to: now } });
-    const mathInstances = instances.instances.filter(i => i.instanceId.indexOf("math ") === 0);
+    const mathInstances = instances.instances.filter(i => i.instanceId.indexOf(`${workflow.name} `) === 0);
 
     assert.ok(mathInstances.length >= 1);
 });