Merge pull request #3 from fterrag/kube2iam-workaround

fterrag · May 17, 2018 · 6104891 · 6104891
2 parents e8e4f90 + fa47723
commit 6104891
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cmd/simplesqsd/simplesqsd.go b/cmd/simplesqsd/simplesqsd.go
@@ -71,16 +71,16 @@ func main() {
 		WithRegion(c.QueueRegion).
 		WithHTTPClient(httpClient)
 
+	sqsSvc := sqs.New(awsSess, sqsConfig)
+
 	// To workaround a kube2iam issue, expire credentials every minute.
 	go func() {
 		for {
-			sqsConfig.Credentials.Expire()
+			sqsSvc.Config.Credentials.Expire()
 			time.Sleep(time.Minute)
 		}
 	}()
 
-	sqsSvc := sqs.New(awsSess, sqsConfig)
-
 	wConf := supervisor.WorkerConfig{
 		QueueURL:         c.QueueURL,
 		QueueMaxMessages: c.QueueMaxMessages,