Skip to content

Commit 68acc6d

Browse files
committed
fix query
1 parent 4f6d10f commit 68acc6d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

services/actions/concurrency.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import (
1111

1212
func CancelActionRunByConcurrency(ctx context.Context, run *actions_model.ActionRun) error {
1313
return actions_model.CancelPreviousJobsWithOpts(ctx, &actions_model.FindRunOptions{
14+
RepoID: run.RepoID,
1415
ConcurrencyGroup: run.ConcurrencyGroup,
1516
Status: []actions_model.Status{
1617
actions_model.StatusRunning,

services/actions/job_emitter.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,10 +64,9 @@ func checkJobsByRunID(ctx context.Context, runID int64) error {
6464
return nil
6565
}
6666
concurrentActionRuns, err := db.Find[actions_model.ActionRun](ctx, &actions_model.FindRunOptions{
67+
RepoID: run.RepoID,
6768
ConcurrencyGroup: run.ConcurrencyGroup,
6869
Status: []actions_model.Status{
69-
actions_model.StatusRunning,
70-
actions_model.StatusWaiting,
7170
actions_model.StatusBlocked,
7271
},
7372
SortType: "oldest",

0 commit comments

Comments
 (0)