fix: gcs manager cancels context

rudderlabs · Nov 7, 2022 · 6520822 · 6520822
1 parent 0312c55
commit 6520822
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/services/filemanager/gcsmanager.go b/services/filemanager/gcsmanager.go
@@ -66,12 +66,9 @@ func (manager *GCSManager) ListFilesWithPrefix(ctx context.Context, startAfter,
 		return
 	}
 
-	ctx, cancel := context.WithTimeout(ctx, manager.getTimeout())
-	defer cancel()
-
 	// Create GCS Bucket handle
 	if manager.Config.Iterator == nil {
-		manager.Config.Iterator = client.Bucket(manager.Config.Bucket).Objects(ctx, &storage.Query{
+		manager.Config.Iterator = client.Bucket(manager.Config.Bucket).Objects(context.Background(), &storage.Query{
 			Prefix:      prefix,
 			Delimiter:   "",
 			StartOffset: startAfter,