working commit
This commit is contained in:
@@ -374,7 +374,6 @@ func (oper *Operator) DeleteColletion(ctx context.Context, operID string, param
|
|||||||
code := http.StatusInternalServerError
|
code := http.StatusInternalServerError
|
||||||
return code, res, err
|
return code, res, err
|
||||||
}
|
}
|
||||||
oper.logg.Debugf("=== %s", param.Path)
|
|
||||||
fileDescrs, err := oper.mdb.ListFilesByCollection(ctx, param.Path)
|
fileDescrs, err := oper.mdb.ListFilesByCollection(ctx, param.Path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
code := http.StatusInternalServerError
|
code := http.StatusInternalServerError
|
||||||
@@ -386,8 +385,6 @@ func (oper *Operator) DeleteColletion(ctx context.Context, operID string, param
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
oper.logg.Warningf("%v", err)
|
oper.logg.Warningf("%v", err)
|
||||||
err = nil
|
err = nil
|
||||||
//code := http.StatusInternalServerError
|
|
||||||
//return code, res, err
|
|
||||||
}
|
}
|
||||||
err = oper.mdb.DeleteFileByCollectionName(ctx, file.Collection, file.Name)
|
err = oper.mdb.DeleteFileByCollectionName(ctx, file.Collection, file.Name)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user