174
continue
175
}
176
>
bufferedStarts = append(bufferedStarts, &schedulespb.BufferedStart{
spec_processor.go
177
>
NominalTime: timestamppb.New(next.Nominal),
178
>
ActualTime: timestamppb.New(next.Next),
179
>
OverlapPolicy: overlapPolicy,
180
>
Manual: manual,
181
>
RequestId: generateRequestID(scheduler, backfillID, next.Nominal, next.Next),
182
>
WorkflowId: schedulescommon.GenerateWorkflowID(workflowID, next.Nominal),
183
>
})
184
>
185
>
if limit != nil {
186
if (*limit)--; *limit <= 0 {
187
// For manual (backfill) actions, break immediately so the caller