()
| 39 | } |
| 40 | |
| 41 | func (t *Task) Name() string { |
| 42 | var buffer bytes.Buffer |
| 43 | if t.Step.Name != "" { |
| 44 | buffer.WriteString(t.Step.Name) |
| 45 | } else { |
| 46 | buffer.WriteString("t") |
| 47 | } |
| 48 | buffer.WriteString(strconv.Itoa(t.Step.Id)) |
| 49 | if len(t.Step.Tasks) > 1 { |
| 50 | buffer.WriteString("_") |
| 51 | buffer.WriteString(strconv.Itoa(t.Id)) |
| 52 | buffer.WriteString("_") |
| 53 | buffer.WriteString(strconv.Itoa(len(t.Step.Tasks))) |
| 54 | } |
| 55 | return buffer.String() |
| 56 | } |
| 57 | |
| 58 | func (t *Task) InputChan() chan reflect.Value { |
| 59 | if len(t.InputChans) != 1 { |
no test coverage detected