Skip to content

Commit dcedee1

Browse files
committed
fix(rivetkit): keep actor alive while workflow waits for queue messages
1 parent 0eb8f51 commit dcedee1

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

  • rivetkit-typescript/packages/rivetkit/src/workflow

rivetkit-typescript/packages/rivetkit/src/workflow/driver.ts

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -223,9 +223,11 @@ export class ActorWorkflowDriver implements EngineDriver {
223223
messageNames: string[],
224224
abortSignal: AbortSignal,
225225
): Promise<void> {
226-
return this.#actor.queueManager.waitForNames(
227-
messageNames.length > 0 ? messageNames : undefined,
228-
abortSignal,
226+
return this.#runCtx.internalKeepAwake(
227+
this.#actor.queueManager.waitForNames(
228+
messageNames.length > 0 ? messageNames : undefined,
229+
abortSignal,
230+
),
229231
);
230232
}
231233
}

0 commit comments

Comments
 (0)