Skip to content

Commit cf16aa3

Browse files
author
Miguel Varela Ramos
authored
Improve async gateway logging (#2070)
1 parent c78f7f5 commit cf16aa3

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

async-gateway/main.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,6 @@ func main() {
112112
}
113113

114114
s3Storage := NewS3(sess, *bucket)
115-
116115
sqsQueue := NewSQS(*queueURL, sess)
117116

118117
svc := NewService(*clusterName, apiName, sqsQueue, s3Storage, log)

async-gateway/service.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ func NewService(clusterName, apiName string, queue Queue, storage Storage, logge
5353
// CreateWorkload enqueues an async workload request and uploads the request payload to S3
5454
func (s *service) CreateWorkload(id string, payload io.Reader, contentType string) (string, error) {
5555
prefix := s.workloadStoragePrefix()
56-
log := s.logger.With(zap.String("id", "id"), zap.String("contentType", contentType))
56+
log := s.logger.With(zap.String("id", id), zap.String("contentType", contentType))
5757

5858
payloadPath := fmt.Sprintf("%s/%s/payload", prefix, id)
5959
log.Debug("uploading payload", zap.String("path", payloadPath))

0 commit comments

Comments
 (0)