a
/
agola
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

runservice: trigger run event in change run phase action

This commit is contained in:
Simone Gotti 2019-05-15 09:41:56 +02:00
parent 846567b96a
commit ac893f1c91
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/services/runservice/action/action.go
View File

@ -71,12 +71,18 @@ func (h *ActionHandler) ChangeRunPhase(ctx context.Context, req *RunChangePhaseR
return err return err
} }
var runEvent *types.RunEvent
switch req.Phase { switch req.Phase {
case types.RunPhaseRunning: case types.RunPhaseRunning:
if r.Phase != types.RunPhaseQueued { if r.Phase != types.RunPhaseQueued {
return errors.Errorf("run %s is not queued but in %q phase", r.ID, r.Phase) return errors.Errorf("run %s is not queued but in %q phase", r.ID, r.Phase)
} }
r.ChangePhase(types.RunPhaseRunning) r.ChangePhase(types.RunPhaseRunning)
runEvent, err = common.NewRunEvent(ctx, h.e, r.ID, r.Phase, r.Result)
if err != nil {
return err
}
case types.RunPhaseFinished: case types.RunPhaseFinished:
if r.Phase != types.RunPhaseRunning { if r.Phase != types.RunPhaseRunning {
return errors.Errorf("run %s is not running but in %q phase", r.ID, r.Phase) return errors.Errorf("run %s is not running but in %q phase", r.ID, r.Phase)
@ -84,7 +90,7 @@ func (h *ActionHandler) ChangeRunPhase(ctx context.Context, req *RunChangePhaseR
r.Stop = true r.Stop = true
} }
_, err = store.AtomicPutRun(ctx, h.e, r, nil, cgt) _, err = store.AtomicPutRun(ctx, h.e, r, runEvent, cgt)
return err return err
} }