agent with tool input deletion case

Author: icecrasher321

apps/sim/socket/index.ts

@@ -58,6 +58,10 @@ async function main() {
   })
 
   process.on('unhandledRejection', (reason, promise) => {
+    if (reason instanceof Error && reason.message === 'The client is closed') {
+      logger.warn('Redis client is closed — suppressing unhandled rejection')
+      return
+    }
     logger.error('Unhandled Rejection at:', promise, 'reason:', reason)
   })
 

apps/sim/stores/operation-queue/store.ts

@@ -2,6 +2,16 @@ import { createLogger } from '@sim/logger'
 import { create } from 'zustand'
 import type { OperationQueueState, QueuedOperation } from './types'
 
+function isBlockStillPresent(blockId: string | undefined): boolean {
+  if (!blockId) return true
+  try {
+    const { useWorkflowStore } = require('@/stores/workflows/workflow/store')
+    return Boolean(useWorkflowStore.getState().blocks[blockId])
+  } catch {
+    return true
+  }
+}
+
 const logger = createLogger('OperationQueue')
 
 /** Timeout for subblock/variable operations before considering them failed */
@@ -220,6 +230,20 @@ export const useOperationQueueStore = create<OperationQueueState>((set, get) =>
     }
 
     if (!retryable) {
+      const targetBlockId = operation.operation.payload?.blockId || operation.operation.payload?.id
+      if (targetBlockId && !isBlockStillPresent(targetBlockId)) {
+        logger.debug('Dropping failed operation for deleted block', {
+          operationId,
+          blockId: targetBlockId,
+        })
+        set((s) => ({
+          operations: s.operations.filter((op) => op.id !== operationId),
+          isProcessing: false,
+        }))
+        get().processNextOperation()
+        return
+      }
+
       logger.error(
         'Operation failed with non-retryable error - state out of sync, triggering offline mode',
         {