AWS S3: fix invalid prefix

google · Jan 13, 2025 · c41dce2 · c41dce2
1 parent f610b64
commit c41dce2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/internal/tailer/logstream/awss3.go b/internal/tailer/logstream/awss3.go
@@ -168,7 +168,10 @@ func (fs *s3Stream) stream(ctx context.Context, wg *sync.WaitGroup, waker waker.
 		for {
 			input := &s3.ListObjectsV2Input{
 				Bucket: &fs.bucket,
-				Prefix: &fs.prefix,
+			}
+
+			if fs.prefix != "" {
+				input.Prefix = &fs.prefix
 			}
 
 			if fs.lastKey != "" {