(wg *sync.WaitGroup)
| 153 | } |
| 154 | |
| 155 | func (tr *TaskRunner) connectExternalOutputs(wg *sync.WaitGroup) { |
| 156 | lastTask := tr.Tasks[len(tr.Tasks)-1] |
| 157 | for _, shard := range lastTask.Outputs { |
| 158 | writeChanName := tr.option.ExecutableFileHash + "-" + shard.Name() |
| 159 | // println("taskGroup", tr.option.TaskGroupId, "step", lastTask.Step.Id, "lastTask", lastTask.Id, "writing to:", writeChanName, "on", tr.option.AgentAddress) |
| 160 | rawChan, err := netchan.GetDirectSendChannel(tr.option.TaskTlsConfig, writeChanName, tr.option.AgentAddress, wg) |
| 161 | if err != nil { |
| 162 | log.Panic(err) |
| 163 | } |
| 164 | outChanStatus := netchan.ConnectTypedWriteChannelToRaw(shard.WriteChan, rawChan, wg) |
| 165 | outChanStatus.Name = shard.DisplayName() |
| 166 | tr.executorStatus.OutputChannelStatuses = append(tr.executorStatus.OutputChannelStatuses, outChanStatus) |
| 167 | } |
| 168 | } |
| 169 | |
| 170 | func (tr *TaskRunner) reportLocalExecutorStatusOnce() { |
| 171 | scheduler.RemoteDirectCommand(tr.option.TaskTlsConfig, tr.option.AgentAddress, &cmd.ControlMessage{ |
no test coverage detected