Static sleep.

artie-labs · Jun 27, 2024 · e6a1e73 · e6a1e73
1 parent ae9c5f2
commit e6a1e73
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/sources/dynamodb/shard.go b/sources/dynamodb/shard.go
@@ -30,10 +30,9 @@ func (s *StreamStore) processShard(ctx context.Context, shard *dynamodbstreams.S
 
 	if shard.ParentShardId != nil {
 		parentID := *shard.ParentShardId
-		if !s.storage.GetShardProcessed(parentID) && s.storage.GetShardProcessing(parentID) {
-			slog.Info("Parent shard is being processed, let's sleep and retry", slog.String("shardId", *shard.ShardId))
-
-			time.Sleep(jitter.Jitter(500, jitter.DefaultMaxMs, 0))
+		if s.storage.GetShardProcessing(parentID) && !s.storage.GetShardProcessed(parentID) {
+			slog.Info("Parent shard is being processed, let's sleep 3s and retry", slog.String("shardId", *shard.ShardId))
+			time.Sleep(3 * time.Second)
 			s.processShard(ctx, shard, writer)
 			return
 		}