fix(dups): onConntext being called twice for a signle edge, once in onConnectEnd and onConnectExtended

* feat(logs-context-menu): consolidated logs utils and types, added logs record context menu (#2659)

* feat(email): welcome email; improvement(emails): ui/ux (#2658)

* feat(email): welcome email; improvement(emails): ui/ux

* improvement(emails): links, accounts, preview

* refactor(emails): file structure and wrapper components

* added envvar for personal emails sent, added isHosted gate

* fixed failing tests, added env mock

* fix: removed comment

---------

Co-authored-by: waleed <walif6@gmail.com>

* fix(logging): hitl + trigger dev crash protection (#2664)

* hitl gaps

* deal with trigger worker crashes

* cleanup import strcuture

* feat(imap): added support for imap trigger (#2663)

* feat(tools): added support for imap trigger

* feat(imap): added parity, tested

* ack PR comments

* final cleanup

* feat(i18n): update translations (#2665)

Co-authored-by: waleedlatif1 <waleedlatif1@users.noreply.github.com>

* fix(grain): updated grain trigger to auto-establish trigger (#2666)

Co-authored-by: aadamgough <adam@sim.ai>

* feat(admin): routes to manage deployments (#2667)

* feat(admin): routes to manage deployments

* fix naming fo deployed by

* feat(time-picker): added timepicker emcn component, added to playground, added searchable prop for dropdown, added more timezones for schedule, updated license and notice date (#2668)

* feat(time-picker): added timepicker emcn component, added to playground, added searchable prop for dropdown, added more timezones for schedule, updated license and notice date

* removed unused params, cleaned up redundant utils

* improvement(invite): aligned styling (#2669)

* improvement(invite): aligned with rest of app

* fix(invite): error handling

* fix: addressed comments

---------

Co-authored-by: Emir Karabeg <78010029+emir-karabeg@users.noreply.github.com>
Co-authored-by: Vikhyath Mondreti <vikhyathvikku@gmail.com>
Co-authored-by: waleedlatif1 <waleedlatif1@users.noreply.github.com>
Co-authored-by: Adam Gough <77861281+aadamgough@users.noreply.github.com>
Co-authored-by: aadamgough <adam@sim.ai>

apps/sim/lib/workflows/comparison/compare.ts

@@ -24,7 +24,9 @@ export function hasWorkflowChanged(
   deployedState: WorkflowState | null
 ): boolean {
   // If no deployed state exists, then the workflow has changed
-  if (!deployedState) return true
+  if (!deployedState) {
+    return true
+  }
 
   // 1. Compare edges (connections between blocks)
   const currentEdges = currentState.edges || []

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

@@ -95,19 +95,41 @@ export const useOperationQueueStore = create<OperationQueueState>((set, get) =>
       return
     }
 
-    // Enhanced duplicate content check - especially important for block operations
-    const duplicateContent = state.operations.find(
-      (op) =>
-        op.operation.operation === operation.operation.operation &&
-        op.operation.target === operation.operation.target &&
-        op.workflowId === operation.workflowId &&
-        // For block operations, check the block ID specifically
-        ((operation.operation.target === 'block' &&
-          op.operation.payload?.id === operation.operation.payload?.id) ||
-          // For other operations, fall back to full payload comparison
-          (operation.operation.target !== 'block' &&
-            JSON.stringify(op.operation.payload) === JSON.stringify(operation.operation.payload)))
-    )
+    // Enhanced duplicate content check - especially important for block and edge operations
+    const duplicateContent = state.operations.find((op) => {
+      if (
+        op.operation.operation !== operation.operation.operation ||
+        op.operation.target !== operation.operation.target ||
+        op.workflowId !== operation.workflowId
+      ) {
+        return false
+      }
+
+      // For block operations, check the block ID specifically
+      if (operation.operation.target === 'block') {
+        return op.operation.payload?.id === operation.operation.payload?.id
+      }
+
+      // For edge operations (batch-add-edges), check by source→target connection
+      // This prevents duplicate edges with different IDs but same connection
+      if (
+        operation.operation.target === 'edges' &&
+        operation.operation.operation === 'batch-add-edges'
+      ) {
+        const newEdges = operation.operation.payload?.edges || []
+        const existingEdges = op.operation.payload?.edges || []
+        // Check if any new edge has the same source→target as an existing operation's edges
+        return newEdges.some((newEdge: any) =>
+          existingEdges.some(
+            (existingEdge: any) =>
+              existingEdge.source === newEdge.source && existingEdge.target === newEdge.target
+          )
+        )
+      }
+
+      // For other operations, fall back to full payload comparison
+      return JSON.stringify(op.operation.payload) === JSON.stringify(operation.operation.payload)
+    })
 
     const isReplaceStateWorkflowOp =
       operation.operation.target === 'workflow' && operation.operation.operation === 'replace-state'