• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

tensorchord / envd / 18149914564

01 Oct 2025 03:02AM UTC coverage: 42.77% (+0.3%) from 42.475%
18149914564

Pull #2039

github

web-flow
chore(deps): bump the all-actions group across 1 directory with 5 updates

Bumps the all-actions group with 5 updates in the / directory:

| Package | From | To |
| --- | --- | --- |
| [actions/checkout](https://github.com/actions/checkout) | `4` | `5` |
| [actions/setup-go](https://github.com/actions/setup-go) | `5` | `6` |
| [actions/download-artifact](https://github.com/actions/download-artifact) | `4` | `5` |
| [actions/setup-python](https://github.com/actions/setup-python) | `5` | `6` |
| [pypa/cibuildwheel](https://github.com/pypa/cibuildwheel) | `2.23.3` | `3.2.0` |



Updates `actions/checkout` from 4 to 5
- [Release notes](https://github.com/actions/checkout/releases)
- [Changelog](https://github.com/actions/checkout/blob/main/CHANGELOG.md)
- [Commits](https://github.com/actions/checkout/compare/v4...v5)

Updates `actions/setup-go` from 5 to 6
- [Release notes](https://github.com/actions/setup-go/releases)
- [Commits](https://github.com/actions/setup-go/compare/v5...v6)

Updates `actions/download-artifact` from 4 to 5
- [Release notes](https://github.com/actions/download-artifact/releases)
- [Commits](https://github.com/actions/download-artifact/compare/v4...v5)

Updates `actions/setup-python` from 5 to 6
- [Release notes](https://github.com/actions/setup-python/releases)
- [Commits](https://github.com/actions/setup-python/compare/v5...v6)

Updates `pypa/cibuildwheel` from 2.23.3 to 3.2.0
- [Release notes](https://github.com/pypa/cibuildwheel/releases)
- [Changelog](https://github.com/pypa/cibuildwheel/blob/main/docs/changelog.md)
- [Commits](https://github.com/pypa/cibuildwheel/compare/v2.23.3...v3.2.0)

---
updated-dependencies:
- dependency-name: actions/checkout
  dependency-version: '5'
  dependency-type: direct:production
  update-type: version-update:semver-major
  dependency-group: all-actions
- dependency-name: actions/setup-go
  dependency-version: '6'
  dependency-type: direct:production
  update-type: version-update:semver-major
 ... (continued)
Pull Request #2039: chore(deps): bump the all-actions group across 1 directory with 5 updates

5218 of 12200 relevant lines covered (42.77%)

164.72 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

84.32
/pkg/progress/progressui/printer.go
1
// Copyright 2023 The envd Authors
2
// Copyright 2023 The buildkit Authors
3
//
4
// Licensed under the Apache License, Version 2.0 (the "License");
5
// you may not use this file except in compliance with the License.
6
// You may obtain a copy of the License at
7
//
8
//      http://www.apache.org/licenses/LICENSE-2.0
9
//
10
// Unless required by applicable law or agreed to in writing, software
11
// distributed under the License is distributed on an "AS IS" BASIS,
12
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
// See the License for the specific language governing permissions and
14
// limitations under the License.
15

16
package progressui
17

18
import (
19
        "container/ring"
20
        "context"
21
        "fmt"
22
        "io"
23
        "os"
24
        "sort"
25
        "strings"
26
        "time"
27

28
        "github.com/opencontainers/go-digest"
29
        "github.com/tonistiigi/units"
30
)
31

32
const antiFlicker = 5 * time.Second
33
const maxDelay = 10 * time.Second
34
const minTimeDelta = 5 * time.Second
35
const minProgressDelta = 0.05 // %
36

37
const logsBufferSize = 10
38

39
type lastStatus struct {
40
        Current   int64
41
        Timestamp time.Time
42
}
43

44
type textMux struct {
45
        w         io.Writer
46
        current   digest.Digest
47
        last      map[string]lastStatus
48
        notFirst  bool
49
        nextIndex int
50
}
51

52
func (p *textMux) printVtx(t *trace, dgst digest.Digest) {
1,913✔
53
        if p.last == nil {
1,940✔
54
                p.last = make(map[string]lastStatus)
27✔
55
        }
27✔
56

57
        v, ok := t.byDigest[dgst]
1,913✔
58
        if !ok {
1,913✔
59
                return
×
60
        }
×
61

62
        if v.index == 0 {
2,829✔
63
                p.nextIndex++
916✔
64
                v.index = p.nextIndex
916✔
65
        }
916✔
66

67
        if dgst != p.current {
2,887✔
68
                if p.current != "" {
1,001✔
69
                        old := t.byDigest[p.current]
27✔
70
                        if old.logsPartial {
27✔
71
                                fmt.Fprintln(p.w, "")
×
72
                        }
×
73
                        old.logsOffset = 0
27✔
74
                        old.count = 0
27✔
75
                        fmt.Fprintf(p.w, "#%d ...\n", old.index)
27✔
76
                }
77

78
                if p.notFirst {
1,921✔
79
                        fmt.Fprintln(p.w, "")
947✔
80
                } else {
974✔
81
                        p.notFirst = true
27✔
82
                }
27✔
83

84
                if os.Getenv("PROGRESS_NO_TRUNC") == "0" {
974✔
85
                        fmt.Fprintf(p.w, "#%d %s\n", v.index, limitString(v.Name, 72))
×
86
                } else {
974✔
87
                        fmt.Fprintf(p.w, "#%d %s\n", v.index, v.Name)
974✔
88
                }
974✔
89
        }
90

91
        if len(v.events) != 0 {
1,913✔
92
                v.logsOffset = 0
×
93
        }
×
94
        for _, ev := range v.events {
1,913✔
95
                fmt.Fprintf(p.w, "#%d %s\n", v.index, ev)
×
96
        }
×
97
        v.events = v.events[:0]
1,913✔
98

1,913✔
99
        isOpenStatus := false // remote cache loading can currently produce status updates without active vertex
1,913✔
100
        for _, s := range v.statuses {
2,918✔
101
                if _, ok := v.statusUpdates[s.ID]; ok {
1,455✔
102
                        doPrint := true
450✔
103

450✔
104
                        if last, ok := p.last[s.ID]; ok && s.Completed == nil {
513✔
105
                                var progressDelta float64
63✔
106
                                if s.Total > 0 {
89✔
107
                                        progressDelta = float64(s.Current-last.Current) / float64(s.Total)
26✔
108
                                }
26✔
109
                                timeDelta := s.Timestamp.Sub(last.Timestamp)
63✔
110
                                if progressDelta < minProgressDelta && timeDelta < minTimeDelta {
107✔
111
                                        doPrint = false
44✔
112
                                }
44✔
113
                        }
114

115
                        if !doPrint {
494✔
116
                                continue
44✔
117
                        }
118

119
                        p.last[s.ID] = lastStatus{
406✔
120
                                Timestamp: s.Timestamp,
406✔
121
                                Current:   s.Current,
406✔
122
                        }
406✔
123

406✔
124
                        var bytes string
406✔
125
                        if s.Total != 0 {
515✔
126
                                bytes = fmt.Sprintf(" %.2f / %.2f", units.Bytes(s.Current), units.Bytes(s.Total))
109✔
127
                        } else if s.Current != 0 {
427✔
128
                                bytes = fmt.Sprintf(" %.2f", units.Bytes(s.Current))
21✔
129
                        }
21✔
130
                        var tm string
406✔
131
                        endTime := s.Timestamp
406✔
132
                        if s.Completed != nil {
734✔
133
                                endTime = *s.Completed
328✔
134
                        }
328✔
135
                        if s.Started != nil {
812✔
136
                                diff := endTime.Sub(*s.Started).Seconds()
406✔
137
                                if diff > 0.01 {
632✔
138
                                        tm = fmt.Sprintf(" %.1fs", diff)
226✔
139
                                }
226✔
140
                        }
141
                        if s.Completed != nil {
734✔
142
                                tm += " done"
328✔
143
                        } else {
406✔
144
                                isOpenStatus = true
78✔
145
                        }
78✔
146
                        fmt.Fprintf(p.w, "#%d %s%s%s\n", v.index, s.ID, bytes, tm)
406✔
147
                }
148
        }
149
        v.statusUpdates = map[string]struct{}{}
1,913✔
150

1,913✔
151
        for _, w := range v.warnings[v.warningIdx:] {
1,913✔
152
                fmt.Fprintf(p.w, "#%d WARN: %s\n", v.index, w.Short)
×
153
                v.warningIdx++
×
154
        }
×
155

156
        for i, l := range v.logs {
10,683✔
157
                if i == 0 {
9,514✔
158
                        l = l[v.logsOffset:]
744✔
159
                }
744✔
160
                fmt.Fprintf(p.w, "%s", l)
8,770✔
161
                if i != len(v.logs)-1 || !v.logsPartial {
17,185✔
162
                        fmt.Fprintln(p.w, "")
8,415✔
163
                }
8,415✔
164
                if v.logsBuffer == nil {
8,819✔
165
                        v.logsBuffer = ring.New(logsBufferSize)
49✔
166
                }
49✔
167
                v.logsBuffer.Value = l
8,770✔
168
                if !v.logsPartial {
12,317✔
169
                        v.logsBuffer = v.logsBuffer.Next()
3,547✔
170
                }
3,547✔
171
        }
172

173
        if len(v.logs) > 0 {
2,657✔
174
                if v.logsPartial {
1,099✔
175
                        v.logs = v.logs[len(v.logs)-1:]
355✔
176
                        v.logsOffset = len(v.logs[0])
355✔
177
                } else {
744✔
178
                        v.logs = nil
389✔
179
                        v.logsOffset = 0
389✔
180
                }
389✔
181
        }
182

183
        p.current = dgst
1,913✔
184
        if v.isCompleted() && !isOpenStatus {
2,860✔
185
                p.current = ""
947✔
186
                v.count = 0
947✔
187

947✔
188
                if v.Error != "" {
947✔
189
                        if v.logsPartial {
×
190
                                fmt.Fprintln(p.w, "")
×
191
                        }
×
192
                        if strings.HasSuffix(v.Error, context.Canceled.Error()) {
×
193
                                fmt.Fprintf(p.w, "#%d CANCELED\n", v.index)
×
194
                        } else {
×
195
                                fmt.Fprintf(p.w, "#%d ERROR: %s\n", v.index, v.Error)
×
196
                        }
×
197
                } else if v.Cached {
1,441✔
198
                        fmt.Fprintf(p.w, "#%d CACHED\n", v.index)
494✔
199
                } else {
947✔
200
                        tm := ""
453✔
201
                        var ivals []interval
453✔
202
                        for _, ival := range v.intervals {
965✔
203
                                ivals = append(ivals, ival)
512✔
204
                        }
512✔
205
                        ivals = mergeIntervals(ivals)
453✔
206
                        if len(ivals) > 0 {
906✔
207
                                var dt float64
453✔
208
                                for _, ival := range ivals {
965✔
209
                                        dt += ival.duration().Seconds()
512✔
210
                                }
512✔
211
                                tm = fmt.Sprintf(" %.1fs", dt)
453✔
212
                        }
213
                        fmt.Fprintf(p.w, "#%d DONE%s\n", v.index, tm)
453✔
214
                }
215
        }
216

217
        delete(t.updates, dgst)
1,913✔
218
}
219

220
func sortCompleted(t *trace, m map[digest.Digest]struct{}) []digest.Digest {
3,405✔
221
        out := make([]digest.Digest, 0, len(m))
3,405✔
222
        for k := range m {
4,352✔
223
                out = append(out, k)
947✔
224
        }
947✔
225
        sort.Slice(out, func(i, j int) bool {
5,079✔
226
                vtxi := t.byDigest[out[i]]
1,674✔
227
                vtxj := t.byDigest[out[j]]
1,674✔
228
                return vtxi.mostRecentInterval().stop.Before(*vtxj.mostRecentInterval().stop)
1,674✔
229
        })
1,674✔
230
        return out
3,405✔
231
}
232

233
func (p *textMux) print(t *trace) {
3,405✔
234
        completed := map[digest.Digest]struct{}{}
3,405✔
235
        rest := map[digest.Digest]struct{}{}
3,405✔
236

3,405✔
237
        for dgst := range t.updates {
5,548✔
238
                v, ok := t.byDigest[dgst]
2,143✔
239
                if !ok {
2,143✔
240
                        continue
×
241
                }
242
                if v.ProgressGroup != nil || v.hidden {
2,143✔
243
                        // skip vtxs in a group (they are merged into a single vtx) and hidden ones
×
244
                        continue
×
245
                }
246
                if v.isCompleted() {
3,090✔
247
                        completed[dgst] = struct{}{}
947✔
248
                } else {
2,143✔
249
                        rest[dgst] = struct{}{}
1,196✔
250
                }
1,196✔
251
        }
252

253
        current := p.current
3,405✔
254

3,405✔
255
        // items that have completed need to be printed first
3,405✔
256
        if _, ok := completed[current]; ok {
3,552✔
257
                p.printVtx(t, current)
147✔
258
        }
147✔
259

260
        for _, dgst := range sortCompleted(t, completed) {
4,352✔
261
                if dgst != current {
1,747✔
262
                        p.printVtx(t, dgst)
800✔
263
                }
800✔
264
        }
265

266
        if len(rest) == 0 {
5,759✔
267
                if current != "" {
4,690✔
268
                        if v := t.byDigest[current]; v.isStarted() && !v.isCompleted() {
4,602✔
269
                                return
2,266✔
270
                        }
2,266✔
271
                }
272
                // make any open vertex active
273
                for dgst, v := range t.byDigest {
2,882✔
274
                        if v.isStarted() && !v.isCompleted() && v.ProgressGroup == nil && !v.hidden {
2,795✔
275
                                p.printVtx(t, dgst)
1✔
276
                                return
1✔
277
                        }
1✔
278
                }
279
                return
87✔
280
        }
281

282
        // now print the active one
283
        if _, ok := rest[current]; ok {
1,856✔
284
                p.printVtx(t, current)
805✔
285
        }
805✔
286

287
        stats := map[digest.Digest]*vtxStat{}
1,051✔
288
        now := time.Now()
1,051✔
289
        sum := 0.0
1,051✔
290
        var max digest.Digest
1,051✔
291
        if current != "" {
2,019✔
292
                rest[current] = struct{}{}
968✔
293
        }
968✔
294
        for dgst := range rest {
2,410✔
295
                v, ok := t.byDigest[dgst]
1,359✔
296
                if !ok {
1,359✔
297
                        continue
×
298
                }
299
                if v.lastBlockTime == nil {
1,359✔
300
                        // shouldn't happen, but not worth crashing over
×
301
                        continue
×
302
                }
303
                tm := now.Sub(*v.lastBlockTime)
1,359✔
304
                speed := float64(v.count) / tm.Seconds()
1,359✔
305
                overLimit := tm > maxDelay && dgst != current
1,359✔
306
                stats[dgst] = &vtxStat{blockTime: tm, speed: speed, overLimit: overLimit}
1,359✔
307
                sum += speed
1,359✔
308
                if overLimit || max == "" || stats[max].speed < speed {
2,561✔
309
                        max = dgst
1,202✔
310
                }
1,202✔
311
        }
312
        for dgst := range stats {
2,410✔
313
                stats[dgst].share = stats[dgst].speed / sum
1,359✔
314
        }
1,359✔
315

316
        if _, ok := completed[current]; ok || current == "" {
1,211✔
317
                p.printVtx(t, max)
160✔
318
                return
160✔
319
        }
160✔
320

321
        // show items that were hidden
322
        for dgst := range rest {
1,983✔
323
                if stats[dgst].overLimit {
1,092✔
324
                        p.printVtx(t, dgst)
×
325
                        return
×
326
                }
×
327
        }
328

329
        // fair split between vertices
330
        if 1.0/(1.0-stats[current].share)*antiFlicker.Seconds() < stats[current].blockTime.Seconds() {
891✔
331
                p.printVtx(t, max)
×
332
                return
×
333
        }
×
334
}
335

336
type vtxStat struct {
337
        blockTime time.Duration
338
        speed     float64
339
        share     float64
340
        overLimit bool
341
}
342

343
func limitString(s string, l int) string {
×
344
        if len(s) > l {
×
345
                return s[:l] + "..."
×
346
        }
×
347
        return s
×
348
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc