limit reaps to 20 at a time

Author: disintegrator

server/internal/background/activities/reap_functions.go

@@ -70,7 +70,10 @@ func (r *ReapFlyApps) Do(ctx context.Context, req ReapFlyAppsRequest) (*ReapFlyA
 	repo := funcrepo.New(r.db)
 
 	// Get all apps that should be reaped (keeping only the most recent N per project)
-	appsToReap, err := repo.GetFlyAppsToReap(ctx, pgtype.Int8{Int64: r.keepCount, Valid: true})
+	appsToReap, err := repo.GetFlyAppsToReap(ctx, funcrepo.GetFlyAppsToReapParams{
+		KeepCount: pgtype.Int8{Int64: r.keepCount, Valid: true},
+		BatchSize: pgtype.Int8{Int64: 20, Valid: true},
+	})
 	if err != nil {
 		return nil, oops.E(oops.CodeUnexpected, err, "failed to query apps to reap").Log(ctx, logger)
 	}

server/internal/functions/queries.sql

@@ -135,7 +135,8 @@ WHERE
   rd.deployment_rank > @keep_count
   AND fa.status = 'ready'
   AND fa.reaped_at IS NULL
-ORDER BY fa.created_at ASC;
+ORDER BY fa.created_at ASC
+LIMIT @batch_size;
 
 -- name: MarkFlyAppReaped :exec
 UPDATE fly_apps SET