diff --git a/apps/sim/socket/handlers/operations.ts b/apps/sim/socket/handlers/operations.ts
index 5f6071e71..c8c538a33 100644
--- a/apps/sim/socket/handlers/operations.ts
+++ b/apps/sim/socket/handlers/operations.ts
@@ -83,6 +83,9 @@ export function setupOperationsHandlers(socket: AuthenticatedSocket, roomManager
             operation,
             target,
           })
+          if (operationId) {
+            socket.emit('operation-failed', { operationId, error: 'User session not found' })
+          }
           return
         }
 
diff --git a/apps/sim/socket/rooms/redis-manager.ts b/apps/sim/socket/rooms/redis-manager.ts
index 404a91c70..51b22819b 100644
--- a/apps/sim/socket/rooms/redis-manager.ts
+++ b/apps/sim/socket/rooms/redis-manager.ts
@@ -179,6 +179,7 @@ export class RedisRoomManager implements IRoomManager {
       const failed = results.some((result) => result instanceof Error)
       if (failed) {
         logger.error(`Pipeline partially failed when adding user to room`, { workflowId, socketId })
+        throw new Error('Failed to store user session data in Redis')
       }
 
       logger.debug(`Added user ${presence.userId} to workflow ${workflowId} (socket: ${socketId})`)