diff --git a/packages/twenty-server/src/engine/metadata-modules/ai/ai-chat/jobs/stream-agent-chat.job.ts b/packages/twenty-server/src/engine/metadata-modules/ai/ai-chat/jobs/stream-agent-chat.job.ts index 2bf046325b..5ed99249ac 100644 --- a/packages/twenty-server/src/engine/metadata-modules/ai/ai-chat/jobs/stream-agent-chat.job.ts +++ b/packages/twenty-server/src/engine/metadata-modules/ai/ai-chat/jobs/stream-agent-chat.job.ts @@ -122,6 +122,14 @@ export class StreamAgentChatJob { }, }) .catch(() => {}); + + await this.eventPublisherService + .publish({ + threadId: data.threadId, + workspaceId: data.workspaceId, + event: { type: 'queue-updated' }, + }) + .catch(() => {}); throw error; } finally { await this.cancelSubscriberService.unsubscribe(cancelChannel);