Skip to content

fix(go-forwarder): prevent log duplication on SQS event failure#1157

Merged
ndakkoune merged 5 commits into
nabil.dakkoune/go-forwarderfrom
nabil.dakkoune/AWSINTS-3778
Jun 19, 2026
Merged

fix(go-forwarder): prevent log duplication on SQS event failure#1157
ndakkoune merged 5 commits into
nabil.dakkoune/go-forwarderfrom
nabil.dakkoune/AWSINTS-3778

Conversation

@ndakkoune

@ndakkoune ndakkoune commented Jun 18, 2026

Copy link
Copy Markdown
Contributor

This PR fixes the potential log duplication we can encounter if an error is raised on a synchronous SQS invocation (see design doc for more information).

Some bouts of this PR are missing and ended up in a previous PR (here and here).

@github-actions github-actions Bot added the aws label Jun 18, 2026
Comment on lines +96 to +97
if err := forwarder.Retry(ctx); err != nil {
return nil, fmt.Errorf("retry: %w", err)

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Since we moved the handler instantiation out of the pipeline, we fast return on retry invocations at the beginning

@ndakkoune ndakkoune marked this pull request as ready for review June 18, 2026 13:43
@ndakkoune ndakkoune requested a review from a team as a code owner June 18, 2026 13:43
@ndakkoune ndakkoune requested a review from ge0Aja June 19, 2026 08:19
Comment thread aws/logs_monitoring_go/internal/parsing/sns.go Outdated
Comment thread aws/logs_monitoring_go/internal/pipeline/pipeline.go Outdated

@ge0Aja ge0Aja left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

@datadog-prod-us1-5

This comment has been minimized.

@ndakkoune ndakkoune merged commit 5209713 into nabil.dakkoune/go-forwarder Jun 19, 2026
10 checks passed
@ndakkoune ndakkoune deleted the nabil.dakkoune/AWSINTS-3778 branch June 19, 2026 13:11
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants