working impl

This commit is contained in:
Vikhyath Mondreti
2025-07-12 18:34:31 -07:00
parent f16d759d8d
commit 9a954d1830

View File

@@ -227,21 +227,6 @@ export const useOperationQueueStore = create<OperationQueueState>((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) =>