V1 to CHASM scheduler migration RPC

chasm/lib/scheduler/backfiller.go

@@ -34,18 +34,23 @@ func addBackfiller(
 	scheduler *Scheduler,
 ) *Backfiller {
 	id := schedulescommon.GenerateBackfillerID()
-	backfiller := &Backfiller{
-		BackfillerState: &schedulerpb.BackfillerState{
-			BackfillId:        id,
-			LastProcessedTime: timestamppb.New(ctx.Now(scheduler)),
-		},
-	}
+	backfiller := newBackfillerWithState(ctx, &schedulerpb.BackfillerState{
+		BackfillId:        id,
+		LastProcessedTime: timestamppb.New(ctx.Now(scheduler)),
+	})
 
 	if scheduler.Backfillers == nil {
 		scheduler.Backfillers = make(chasm.Map[string, *Backfiller])
 	}
 	scheduler.Backfillers[id] = chasm.NewComponentField(ctx, backfiller)
 
+	return backfiller
+}
+
+func newBackfillerWithState(ctx chasm.MutableContext, state *schedulerpb.BackfillerState) *Backfiller {
+	backfiller := &Backfiller{
+		BackfillerState: state,
+	}
 	backfiller.scheduleTask(ctx, chasm.TaskScheduledTimeImmediate)
 	return backfiller
 }