|
|
|
@@ -856,16 +856,17 @@ func CompleteMultipart(ctx *context.Context) { |
|
|
|
|
|
|
|
if typeCloudBrain == models.TypeCloudBrainOne { |
|
|
|
_, err = storage.CompleteMultiPartUpload(uuid, uploadID, fileChunk.TotalChunks) |
|
|
|
if err != nil { |
|
|
|
ctx.Error(500, fmt.Sprintf("CompleteMultiPartUpload failed: %v", err)) |
|
|
|
return |
|
|
|
} |
|
|
|
} else { |
|
|
|
err = storage.CompleteObsMultiPartUpload(uuid, uploadID, fileName, fileChunk.TotalChunks) |
|
|
|
if err != nil { |
|
|
|
ctx.Error(500, fmt.Sprintf("CompleteObsMultiPartUpload failed: %v", err)) |
|
|
|
return |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if err != nil { |
|
|
|
log.Error("CompleteMultiPartUpload(uuid:%s) failed: %v", uuid, err, ctx.Data["MsgID"]) |
|
|
|
ctx.JSON(200, map[string]string{ |
|
|
|
"result_code": "-1", |
|
|
|
"err_msg": ctx.Tr("repo.dataset.error.complete"), |
|
|
|
}) |
|
|
|
return |
|
|
|
} |
|
|
|
|
|
|
|
fileChunk.IsUploaded = models.FileUploaded |
|
|
|
|