Skip to content

Commit ce26e8f

Browse files
Fix comment
Signed-off-by: Peter Broadhurst <[email protected]>
1 parent f767c43 commit ce26e8f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

internal/events/persist_batch.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -335,7 +335,7 @@ func (em *eventManager) persistBatchContent(ctx context.Context, batch *core.Bat
335335
})
336336
}
337337
}
338-
// If we have an error at this point, we're cannot insert (must not be a duplicate)
338+
// If we have an error at this point, we cannot insert (must not be a duplicate)
339339
if err != nil {
340340
log.L(ctx).Errorf("Failed to insert messages: %s", err)
341341
return false, err // a persistence failure here is considered retryable (so returned)

0 commit comments

Comments
 (0)