@@ -30,9 +30,8 @@ const fileCacheType = "buildkit.file.v0"
30
30
31
31
type fileOp struct {
32
32
op * pb.FileOp
33
- md cache.MetadataStore
34
33
w worker.Worker
35
- solver * FileOpSolver
34
+ refManager * file. RefManager
36
35
numInputs int
37
36
parallelism * semaphore.Weighted
38
37
}
@@ -41,12 +40,12 @@ func NewFileOp(v solver.Vertex, op *pb.Op_File, cm cache.Manager, parallelism *s
41
40
if err := opsutils .Validate (& pb.Op {Op : op }); err != nil {
42
41
return nil , err
43
42
}
43
+ refManager := file .NewRefManager (cm , v .Name ())
44
44
return & fileOp {
45
45
op : op .File ,
46
- md : cm ,
47
- numInputs : len (v .Inputs ()),
48
46
w : w ,
49
- solver : NewFileOpSolver (w , & file.Backend {}, file .NewRefManager (cm , v .Name ())),
47
+ refManager : refManager ,
48
+ numInputs : len (v .Inputs ()),
50
49
parallelism : parallelism ,
51
50
}, nil
52
51
}
@@ -168,7 +167,8 @@ func (f *fileOp) Exec(ctx context.Context, g session.Group, inputs []solver.Resu
168
167
inpRefs = append (inpRefs , workerRef .ImmutableRef )
169
168
}
170
169
171
- outs , err := f .solver .Solve (ctx , inpRefs , f .op .Actions , g )
170
+ fs := NewFileOpSolver (f .w , & file.Backend {}, f .refManager )
171
+ outs , err := fs .Solve (ctx , inpRefs , f .op .Actions , g )
172
172
if err != nil {
173
173
return nil , err
174
174
}
0 commit comments