MCPcopy Create free account
hub / github.com/53AI/53AIHub / updateBatchStatus

Method updateBatchStatus

api/service/batch_upload_manager.go:405–425  ·  view source on GitHub ↗

updateBatchStatus 更新批次状态

(batch *BatchUpload)

Source from the content-addressed store, hash-verified

403
404// updateBatchStatus 更新批次状态
405func (m *BatchUploadManager) updateBatchStatus(batch *BatchUpload) {
406 if batch == nil {
407 return
408 }
409 m.mu.Lock()
410 if batch.Status != "cancelled" {
411 if batch.UploadedFiles+batch.FailedFiles >= batch.TotalFiles {
412 if batch.FailedFiles == 0 {
413 batch.Status = "completed"
414 } else {
415 batch.Status = "failed"
416 }
417 } else {
418 batch.Status = "uploading"
419 }
420 }
421 batch.UpdatedAt = time.Now()
422 m.mu.Unlock()
423
424 m.progressStorage.SaveBatch(batch)
425}
426
427// CancelBatch 取消批量上传
428func (m *BatchUploadManager) CancelBatch(batchID string) error {

Callers 1

processUploadTaskMethod · 0.95

Calls 2

SaveBatchMethod · 0.80
UnlockMethod · 0.65

Tested by

no test coverage detected