apiserver: Handle BucketExists() error

kubeflow · Mar 23, 2020 · b1d8c4d · b1d8c4d
1 parent 302cb07
commit b1d8c4d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/backend/src/apiserver/client_manager.go b/backend/src/apiserver/client_manager.go
@@ -346,6 +346,9 @@ func initMinioClient(initConnectionTimeout time.Duration) storage.ObjectStoreInt
 func createMinioBucket(minioClient *minio.Client, bucketName, region string) {
 	// Check to see if we already own this bucket.
 	exists, err := minioClient.BucketExists(bucketName)
+	if err != nil {
+		glog.Fatalf("Failed to check if Minio bucket exists. Error: %v", err)
+	}
 	if exists {
 		glog.Infof("We already own %s\n", bucketName)
 		return