解决上传的临时文件不会被删除的bug

agent/internal/task/cache_move_package.go

@@ -77,6 +77,7 @@ func (t *CacheMovePackage) do(ctx TaskContext) error {
 		writer := store.New()
 		_, err = io.Copy(writer, obj.File)
 		if err != nil {
+			writer.Abort()
 			return fmt.Errorf("writing to store: %w", err)
 		}
 		_, err = writer.Finish()

common/pkgs/storage/local/shard_store.go

@@ -226,6 +226,8 @@ func (s *ShardStore) onWritterFinish(w *ShardWriter, hash cdssdk.FileHash) (type
 		s.removeTempFile(w.path)
 		log.Warnf("get file %v stat: %v", newPath, err)
 		return types.FileInfo{}, fmt.Errorf("get file stat: %w", err)
+	} else {
+		s.removeTempFile(w.path)
 	}
 
 	return types.FileInfo{

common/pkgs/storage/types/shard_store.go

@@ -65,8 +65,7 @@ type Stats struct {
 
 type ShardWriter interface {
 	io.Writer
-	// 取消写入。要求允许在调用了Finish之后再调用此函数，且此时不应该有任何影响。
-	// 方便defer机制
+	// 取消写入。要求允许在调用了Finish之后再调用此函数，且此时不应该有任何影响，方便使用defer语句
 	Abort() error
 	// 结束写入，获得文件哈希值
 	Finish() (FileInfo, error)