Skip to content

Commit c3cb850

Browse files
committed
fix queue lifecycle context isolation in _flushQueue
1 parent 64b7a86 commit c3cb850

1 file changed

Lines changed: 0 additions & 8 deletions

File tree

packages/agents/src/index.ts

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -2258,14 +2258,6 @@ export class Agent<
22582258
}
22592259
};
22602260

2261-
const store = agentContext.getStore();
2262-
// workerd propagates AsyncLocalStorage through promises/timers, so
2263-
// queue flushing inside an active agent scope should inherit context.
2264-
if (store?.agent === this) {
2265-
await runQueueCallback();
2266-
continue;
2267-
}
2268-
22692261
const contextInput: AgentContextInput = {
22702262
lifecycle: "queue",
22712263
agent: this,

0 commit comments

Comments
 (0)