add comments

Author: disintegrator

server/internal/background/activities/reap_functions.go

@@ -72,6 +72,8 @@ func (r *ReapFlyApps) Do(ctx context.Context, req ReapFlyAppsRequest) (*ReapFlyA
 	// Get all apps that should be reaped (keeping only the most recent N per project)
 	appsToReap, err := repo.GetFlyAppsToReap(ctx, funcrepo.GetFlyAppsToReapParams{
 		KeepCount: pgtype.Int8{Int64: r.keepCount, Valid: true},
+		// Starting with a small batch size for now and we'll increase later on
+		// after some observation.
 		BatchSize: pgtype.Int8{Int64: 20, Valid: true},
 	})
 	if err != nil {

server/internal/background/deployments.go

@@ -193,6 +193,9 @@ func ProcessDeploymentWorkflow(ctx workflow.Context, params ProcessDeploymentWor
 			string(attr.DeploymentIDKey), params.DeploymentID,
 		)
 		_, err = ExecuteProjectFunctionsReaperChildWorkflow(ctx, params.ProjectID)
+		// Many deployments can run in parallel in a given project but only one
+		// reaper should be active at a time, so we ignore the already started
+		// error if we get that back.
 		if err != nil && !temporal.IsWorkflowExecutionAlreadyStartedError(err) {
 			logger.Error(
 				"failed to start project-scoped functions reaper workflow",