PR FIXUP - Return error instead of logging

db/descriptions/schema.go

@@ -118,43 +118,46 @@ func GetSchemas(
 	if err != nil {
 		return nil, NewErrFailedToCreateSchemaQuery(err)
 	}
-	defer func() {
-		if err := collectionSchemaVersionQuery.Close(); err != nil {
-			log.Error(ctx, NewErrFailedToCloseSchemaQuery(err).Error())
-		}
-	}()
 
 	versionIDs := make([]string, 0)
 	for res := range collectionSchemaVersionQuery.Next() {
 		if res.Error != nil {
+			if err := collectionSchemaVersionQuery.Close(); err != nil {
+				return nil, NewErrFailedToCloseSchemaQuery(err)
+			}
 			return nil, err
 		}
 
 		versionIDs = append(versionIDs, core.NewCollectionSchemaVersionKeyFromString(string(res.Key)).SchemaVersionId)
 	}
 
+	if err := collectionSchemaVersionQuery.Close(); err != nil {
+		return nil, NewErrFailedToCloseSchemaQuery(err)
+	}
+
 	schemaVersionPrefix := core.NewSchemaVersionKey("")
 	schemaVersionQuery, err := txn.Systemstore().Query(ctx, query.Query{
 		Prefix: schemaVersionPrefix.ToString(),
 	})
 	if err != nil {
 		return nil, NewErrFailedToCreateSchemaQuery(err)
 	}
-	defer func() {
-		if err := schemaVersionQuery.Close(); err != nil {
-			log.Error(ctx, NewErrFailedToCloseSchemaQuery(err).Error())
-		}
-	}()
 
 	descriptions := make([]client.SchemaDescription, 0)
 	for res := range schemaVersionQuery.Next() {
 		if res.Error != nil {
+			if err := schemaVersionQuery.Close(); err != nil {
+				return nil, NewErrFailedToCloseSchemaQuery(err)
+			}
 			return nil, err
 		}
 
 		var desc client.SchemaDescription
 		err = json.Unmarshal(res.Value, &desc)
 		if err != nil {
+			if err := schemaVersionQuery.Close(); err != nil {
+				return nil, NewErrFailedToCloseSchemaQuery(err)
+			}
 			return nil, err
 		}
 
@@ -166,5 +169,9 @@ func GetSchemas(
 		}
 	}
 
+	if err := schemaVersionQuery.Close(); err != nil {
+		return nil, NewErrFailedToCloseSchemaQuery(err)
+	}
+
 	return descriptions, nil
 }