diff --git a/async-gateway/main.go b/async-gateway/main.go index b37a51661f..f24f0da602 100644 --- a/async-gateway/main.go +++ b/async-gateway/main.go @@ -112,7 +112,6 @@ func main() { } s3Storage := NewS3(sess, *bucket) - sqsQueue := NewSQS(*queueURL, sess) svc := NewService(*clusterName, apiName, sqsQueue, s3Storage, log) diff --git a/async-gateway/service.go b/async-gateway/service.go index 3769f787c6..f11257bdff 100644 --- a/async-gateway/service.go +++ b/async-gateway/service.go @@ -53,7 +53,7 @@ func NewService(clusterName, apiName string, queue Queue, storage Storage, logge // CreateWorkload enqueues an async workload request and uploads the request payload to S3 func (s *service) CreateWorkload(id string, payload io.Reader, contentType string) (string, error) { prefix := s.workloadStoragePrefix() - log := s.logger.With(zap.String("id", "id"), zap.String("contentType", contentType)) + log := s.logger.With(zap.String("id", id), zap.String("contentType", contentType)) payloadPath := fmt.Sprintf("%s/%s/payload", prefix, id) log.Debug("uploading payload", zap.String("path", payloadPath))