From 9a954d1830fea3ffadecc78a9c93aaada6860563 Mon Sep 17 00:00:00 2001 From: Vikhyath Mondreti Date: Sat, 12 Jul 2025 18:34:31 -0700 Subject: [PATCH] working impl --- apps/sim/stores/operation-queue/store.ts | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/apps/sim/stores/operation-queue/store.ts b/apps/sim/stores/operation-queue/store.ts index 380e3f9ffc..f36f52e252 100644 --- a/apps/sim/stores/operation-queue/store.ts +++ b/apps/sim/stores/operation-queue/store.ts @@ -227,21 +227,6 @@ export const useOperationQueueStore = create((set, get) => return // No pending operations } - // Check workflow context - if (nextOperation.workflowId !== currentWorkflowId) { - logger.warn('Cancelling operation - workflow changed', { - operationId: nextOperation.id, - operationWorkflow: nextOperation.workflowId, - currentWorkflow: currentWorkflowId, - }) - set((state) => ({ - operations: state.operations.filter((op) => op.id !== nextOperation.id), - })) - // Try next operation - get().processNextOperation() - return - } - // Mark as processing set((state) => ({ operations: state.operations.map((op) =>