Skip to content

Commit 54ae67c

Browse files
committed
handle ctx cancel
1 parent a294142 commit 54ae67c

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

services/packages/cleanup/cleanup.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -85,12 +85,6 @@ func executeCleanupOneRulePackage(ctx context.Context, pcr *packages_model.Packa
8585
}
8686

8787
func executeCleanupOneRule(ctx context.Context, pcr *packages_model.PackageCleanupRule) error {
88-
select {
89-
case <-ctx.Done():
90-
return db.ErrCancelledf("While processing package cleanup rules")
91-
default:
92-
}
93-
9488
if err := pcr.CompiledPattern(); err != nil {
9589
return fmt.Errorf("CleanupRule [%d]: CompilePattern failed: %w", pcr.ID, err)
9690
}
@@ -156,6 +150,12 @@ func executeCleanupOneRule(ctx context.Context, pcr *packages_model.PackageClean
156150

157151
func ExecuteCleanupRules(ctx context.Context) error {
158152
return packages_model.IterateEnabledCleanupRules(ctx, func(ctx context.Context, pcr *packages_model.PackageCleanupRule) error {
153+
select {
154+
case <-ctx.Done():
155+
return db.ErrCancelledf("While processing package cleanup rules")
156+
default:
157+
}
158+
159159
err := executeCleanupOneRule(ctx, pcr)
160160
if err != nil {
161161
log.Error("CleanupRule [%d]: executeCleanupOneRule failed: %v", pcr.ID, err)

0 commit comments

Comments
 (0)