fix path parser

streamnative · Feb 26, 2025 · bce9789 · bce9789
1 parent 5b3d1d4
commit bce9789
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/connection/reconcile_package.go b/pkg/connection/reconcile_package.go
@@ -205,8 +205,13 @@ func downloadCloudStorage(ctx context.Context, fileURL string, tmpFile *os.File)
 		return "", fmt.Errorf("invalid URL: %v", err)
 	}
 
+	objectKey := parsedURL.Path
+	if len(objectKey) > 0 && objectKey[0] == '/' {
+		objectKey = objectKey[1:] // Remove the leading slash
+	}
+
 	// Get the object
-	reader, err := bucket.NewReader(ctx, parsedURL.Path, nil)
+	reader, err := bucket.NewReader(ctx, objectKey, nil)
 	if err != nil {
 		return "", fmt.Errorf("failed to create reader: %v", err)
 	}