fix(workspace-events): skip no_activity subscriptions on the execution-completion path

no_activity is poller-owned and can never fire from a completed execution,
but it passed into the rule branch and cost a pointless cooldown point-read
per subscription on the hottest path. Early-continue alongside the
workflow_deployed guard.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: icecrasher321

apps/sim/lib/workspace-events/emitter.test.ts

@@ -256,6 +256,18 @@ describe('emitExecutionCompletedEvent', () => {
     })
   })
 
+  it('skips no_activity subscriptions before any cooldown read or rule evaluation (poller-owned)', async () => {
+    const sub = makeSubscription(makeConfig({ eventType: 'no_activity' }))
+    mockFetchSubscriptions.mockResolvedValueOnce([sub])
+
+    await emitExecutionCompletedEvent(makeLog())
+
+    expect(mockReadLastFiredAt).not.toHaveBeenCalled()
+    expect(mockEvaluateRule).not.toHaveBeenCalled()
+    expect(mockClaimCooldown).not.toHaveBeenCalled()
+    expect(mockProcessPolledWebhookEvent).not.toHaveBeenCalled()
+  })
+
   it('skips rule evaluation while within the cooldown window', async () => {
     mockReadLastFiredAt.mockResolvedValueOnce(new Date())
     mockFetchSubscriptions.mockResolvedValueOnce([

apps/sim/lib/workspace-events/emitter.ts

@@ -105,6 +105,10 @@ export async function emitExecutionCompletedEvent(log: WorkflowExecutionLog): Pr
       const config = parseSubscriptionConfig(subscription.webhook.providerConfig)
       if (!config) continue
       if (config.eventType === 'workflow_deployed') continue
+      // no_activity is owned by the inactivity poller and can never fire from
+      // a completed execution; skip before the rule branch costs a cooldown
+      // read on this hot path.
+      if (config.eventType === 'no_activity') continue
 
       if (subscription.webhook.workflowId === log.workflowId) continue
       if (!matchesWorkflowScope(config, log.workflowId)) continue