File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -146,8 +146,11 @@ func (w *Worker) exec(index int, config *api.Worker) error {
146
146
break
147
147
}
148
148
149
- // set the outputs container ID
150
- w .Config .Executor .OutputCtn .ID = fmt .Sprintf ("outputs_%s" , p .ID )
149
+ // dereference configured outputs ctn config and set the outputs container ID for the executor
150
+ //
151
+ // need to dereference to avoid executors sharing the last set outputs container config
152
+ execOutputCtn := * w .Config .Executor .OutputCtn
153
+ execOutputCtn .ID = fmt .Sprintf ("outputs_%s" , p .ID )
151
154
152
155
// create logger with extra metadata
153
156
//
@@ -240,7 +243,7 @@ func (w *Worker) exec(index int, config *api.Worker) error {
240
243
Build : item .Build ,
241
244
Pipeline : p .Sanitize (w .Config .Runtime .Driver ),
242
245
Version : v .Semantic (),
243
- OutputCtn : w . Config . Executor . OutputCtn ,
246
+ OutputCtn : & execOutputCtn ,
244
247
})
245
248
246
249
// add the executor to the worker
You can’t perform that action at this time.
0 commit comments