logs: clean up logs for canceled tasks

Signed-off-by: Andrea Luzzardi <aluzzardi@gmail.com>
This commit is contained in:
Andrea Luzzardi 2021-02-24 18:48:55 -08:00
parent e7ec4fc132
commit 074e47d9c0

View File

@ -3,6 +3,7 @@ package dagger
import ( import (
"context" "context"
"fmt" "fmt"
"strings"
"time" "time"
"cuelang.org/go/cue" "cuelang.org/go/cue"
@ -297,18 +298,26 @@ func newPipelineTaskFunc(ctx context.Context, inst *cue.Instance, s Solver) cuef
p := NewPipeline(t.Path().String(), s, NewFillable(t)) p := NewPipeline(t.Path().String(), s, NewFillable(t))
err := p.Do(ctx, v) err := p.Do(ctx, v)
if err != nil { if err != nil {
// FIXME: this should use errdefs.IsCanceled(err)
if strings.Contains(err.Error(), "context canceled") {
lg.
Error().
Dur("duration", time.Since(start)).
Msg("canceled")
return err
}
lg. lg.
Error(). Error().
Dur("duration", time.Since(start)). Dur("duration", time.Since(start)).
Err(err). Err(err).
Msg("failed") Msg("failed")
} else { return err
}
lg. lg.
Info(). Info().
Dur("duration", time.Since(start)). Dur("duration", time.Since(start)).
Msg("completed") Msg("completed")
} return nil
return err
}), nil }), nil
} }
} }