Skip to content

fix(workflows): add observability for action deduplication blocks#55282

Merged
meikelmosby merged 1 commit intomasterfrom
fix/hogflow-dedup-observability
Apr 21, 2026
Merged

fix(workflows): add observability for action deduplication blocks#55282
meikelmosby merged 1 commit intomasterfrom
fix/hogflow-dedup-observability

Conversation

@meikelmosby
Copy link
Copy Markdown
Collaborator

Add a Prometheus counter and logging when the dedup check blocks a workflow action execution. This helps diagnose cases where invocations are unexpectedly blocked as duplicates.

  • hogflow_action_dedup_blocked_total counter
  • Structured logger.warn with both invocation IDs, event UUID, action details
  • User-facing log now includes the existing invocation ID for cross-reference as well

Add a Prometheus counter and structured logging when the dedup check
blocks a workflow action execution. This helps diagnose cases where
invocations are unexpectedly blocked as duplicates.

- hogflow_action_dedup_blocked_total counter (no high-cardinality labels)
- Structured logger.warn with both invocation IDs, event UUID, action details
- User-facing log now includes the existing invocation ID for cross-reference

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
@assign-reviewers-posthog assign-reviewers-posthog Bot requested a review from a team April 20, 2026 13:27
@greptile-apps
Copy link
Copy Markdown
Contributor

greptile-apps Bot commented Apr 20, 2026

Prompt To Fix All With AI
This is a comment left during a code review.
Path: nodejs/src/cdp/services/hogflows/hogflow-executor.service.ts
Line: 487-494

Comment:
**No application-level metric emitted for dedup-blocked invocations**

When an early exit occurs (line 317–332), an application-level metric is pushed onto `earlyExitResult.metrics` so the analytics pipeline records a per-team/per-flow occurrence. The new dedup-blocked path only increments the Prometheus counter — no metric entry is pushed onto `dedupResult.metrics`. This means blocked duplicates won't appear in any team-level workflow metrics dashboard, only in the aggregate Prometheus counter.

Consider adding a `'filtered'` (or a new `'deduplicated'`) metric push here for parity with the early-exit path:

```typescript
this.trackActionMetric(dedupResult, currentAction, 'filtered')
```

How can I resolve this? If you propose a fix, please make it concise.

Reviews (1): Last reviewed commit: "fix(workflows): add observability for ac..." | Re-trigger Greptile

Comment thread nodejs/src/cdp/services/hogflows/hogflow-executor.service.ts
@meikelmosby meikelmosby merged commit f26d672 into master Apr 21, 2026
154 checks passed
@meikelmosby meikelmosby deleted the fix/hogflow-dedup-observability branch April 21, 2026 07:42
@deployment-status-posthog
Copy link
Copy Markdown

deployment-status-posthog Bot commented Apr 21, 2026

Deploy status

Environment Status Deployed At Workflow
dev ✅ Deployed 2026-04-21 08:19 UTC Run
prod-us ✅ Deployed 2026-04-21 08:31 UTC Run
prod-eu ✅ Deployed 2026-04-21 08:33 UTC Run

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants