diff --git a/web/app/components/workflow/collaboration/core/__tests__/crdt-provider.test.ts b/web/app/components/workflow/collaboration/core/__tests__/crdt-provider.test.ts
index 5b07c032ab..6c4fe91d2a 100644
--- a/web/app/components/workflow/collaboration/core/__tests__/crdt-provider.test.ts
+++ b/web/app/components/workflow/collaboration/core/__tests__/crdt-provider.test.ts
@@ -73,6 +73,7 @@ describe('CRDTProvider', () => {
     expect(socket.emit).toHaveBeenCalledWith(
       'graph_event',
       expect.any(Uint8Array),
+      expect.any(Function),
     )
     expect(doc.export).toHaveBeenCalledWith({ mode: 'update' })
   })
diff --git a/web/app/components/workflow/collaboration/core/__tests__/websocket-manager.test.ts b/web/app/components/workflow/collaboration/core/__tests__/websocket-manager.test.ts
index b41845702a..804b773f32 100644
--- a/web/app/components/workflow/collaboration/core/__tests__/websocket-manager.test.ts
+++ b/web/app/components/workflow/collaboration/core/__tests__/websocket-manager.test.ts
@@ -126,7 +126,11 @@ describe('WebSocketClient', () => {
     expect(connectHandler).toBeDefined()
     connectHandler()
 
-    expect(mockSocket.emit).toHaveBeenCalledWith('user_connect', { workflow_id: 'app-auth' })
+    expect(mockSocket.emit).toHaveBeenCalledWith(
+      'user_connect',
+      { workflow_id: 'app-auth' },
+      expect.any(Function),
+    )
   })
 
   it('disconnects a specific app and clears internal maps', async () => {