Skip to content

Commit

Permalink
Fix panic.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Jul 15, 2024
1 parent 8550c2e commit 51f4a9f
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion sources/dynamodb/shard.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ func (s *StreamStore) ListenToChannel(ctx context.Context, writer writers.Writer

func (s *StreamStore) reprocessShard(ctx context.Context, shard *dynamodbstreams.Shard, writer writers.Writer, numErrs int, err error) {
if numErrs > maxNumErrs {
logger.Panic("Failed to call `GetRecords` and max number of attempts reached", err)
logger.Panic(fmt.Sprintf("Failed to process shard: %s and the max number of attempts have been reached: %v", *shard.ShardId, err))
}

slog.Warn("Failed to process shard, going to try again...",
Expand Down

0 comments on commit 51f4a9f

Please sign in to comment.