USEFULL
/
drone
mirror of https://github.com/harness/drone.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

truncate stage and step error messages for pg

pull/2971/head
Brad Rydzewski 2020-05-21 16:48:30 -04:00
parent d1a2f2174d
commit dff798a4d1
3 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
operator/manager/setup.go
View File

@ -76,6 +76,9 @@ func (s *setup) do(ctx context.Context, stage *core.Stage) error {
// return err
// }
if len(stage.Error) > 500 {
stage.Error = stage.Error[:500]
}
stage.Updated = time.Now().Unix()
err = s.Stages.Update(noContext, stage)
if err != nil {
@ -86,6 +89,9 @@ func (s *setup) do(ctx context.Context, stage *core.Stage) error {
}
for _, step := range stage.Steps {
if len(step.Error) > 500 {
step.Error = step.Error[:500]
}
err := s.Steps.Create(noContext, step)
if err != nil {
logger.WithError(err).

7
operator/manager/teardown.go
View File

@ -65,6 +65,9 @@ func (t *teardown) do(ctx context.Context, stage *core.Stage) error {
}
for _, step := range stage.Steps {
if len(step.Error) > 500 {
step.Error = step.Error[:500]
}
err := t.Steps.Update(noContext, step)
if err != nil {
logger.WithError(err).
@ -76,6 +79,10 @@ func (t *teardown) do(ctx context.Context, stage *core.Stage) error {
}
}
if len(stage.Error) > 500 {
stage.Error = stage.Error[:500]
}
stage.Updated = time.Now().Unix()
err = t.Stages.Update(noContext, stage)
if err != nil {

3
operator/manager/updater.go
View File

@ -41,6 +41,9 @@ func (u *updater) do(ctx context.Context, step *core.Step) error {
},
)
if len(step.Error) > 500 {
step.Error = step.Error[:500]
}
err := u.Steps.Update(noContext, step)
if err != nil {
logger.WithError(err).Warnln("manager: cannot update step")