We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
firstItemTime
execout_walker
1 parent db24d6b commit c8d6458Copy full SHA for c8d6458
1 file changed
orchestrator/execout/execout_walker.go
@@ -246,7 +246,9 @@ func (r *Walker) sendItems(reader execout.FileReader) error {
246
iterationStartTime := time.Now()
247
firstItemTime := time.Duration(0)
248
for item, err := range reader.Iter() {
249
- firstItemTime += time.Since(iterationStartTime)
+ if itemCount == 0 {
250
+ firstItemTime = time.Since(iterationStartTime)
251
+ }
252
253
if err != nil {
254
return fmt.Errorf("iterating on execout reader: %w", err)
0 commit comments