Skip to content

Commit 4ddf509

Browse files
committed
fix job_emitter
1 parent 19e2875 commit 4ddf509

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

services/actions/job_emitter.go

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -273,11 +273,8 @@ func (r *jobStatusResolver) resolve(ctx context.Context) map[int64]actions_model
273273

274274
if blockedByJobConcurrency {
275275
continue
276-
}
277-
278-
if err := CancelJobsByJobConcurrency(ctx, r.jobMap[id]); err != nil {
279-
log.Error("Cancel previous jobs for job %d: %v. This job will stay blocked.", id, err)
280-
continue
276+
} else if err := CancelJobsByJobConcurrency(ctx, r.jobMap[id]); err != nil {
277+
log.Error("Cancel previous jobs for job %d: %v", id, err)
281278
}
282279

283280
if allSucceed {

0 commit comments

Comments
 (0)