[to be removed] test

snowplow-devops · Oct 10, 2024 · 2aa48dd · 2aa48dd
1 parent 54a5b63
commit 2aa48dd
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/shard_consumer.go b/shard_consumer.go
@@ -62,6 +62,12 @@ func getRecords(k kinesisiface.KinesisAPI, streamName string, shardID string, it
 		ShardIterator: aws.String(iterator),
 	}
 
+	// sleep for 5 minutes + 5 sec, to make sure the shard iterator expires
+	fmt.Println("Sleeping for 305 seconds")
+	fmt.Printf("pre-sleep time.Now: %s\n", time.Now().Format(time.RFC3339))
+	time.Sleep(305 * time.Second)
+	fmt.Printf("post-sleep time.Now: %s\n", time.Now().Format(time.RFC3339))
+
 	output, err := k.GetRecords(params)
 
 	if err != nil {