142
memo map[string]*commonpb.Payload,
143
migrationTime time.Time,
145
>
schedulerState := common.CloneProto(scheduler)
146
>
if schedulerState == nil {
147
schedulerState = &schedulerpb.SchedulerState{}
148
}
149
151
>
if schedule == nil {
152
schedule = &schedulepb.Schedule{}
153
}
154
156
>
if info == nil {
157
info = &schedulepb.ScheduleInfo{}
158
}
159
161
>
if invoker != nil {
162
>
invokerBuffered = invoker.GetBufferedStarts()
163
>
}
164
>
bufferedStarts, running, recent := splitBufferedStartsForLegacy(invokerBuffered)
165
>
ongoingBackfills, triggerStarts := convertBackfillersCHASMToLegacy(backfillers, migrationTime)
166
>
bufferedStarts = append(bufferedStarts, triggerStarts...)
167
>
168
>
var generatorLastProcessed *timestamppb.Timestamp
169
>
if generator != nil {
170
>
generatorLastProcessed = generator.GetLastProcessedTime()
171
>
}
172
>
lastProcessedTime := common.CloneProto(generatorLastProcessed)
173
>
if lastProcessedTime == nil {
174
lastProcessedTime = timestamppb.New(migrationTime)
175
}
176
177
>
resultPayloads, continuedFailure := convertLastCompletionCHASMToLegacy(lastCompletionResult)
migration.go
178
>
179
>
info.RunningWorkflows = running
180
>
info.RecentActions = recent
181
>
182
>
state := &schedulespb.InternalState{
183
>
Namespace: schedulerState.Namespace,
184
>
NamespaceId: schedulerState.NamespaceId,
185
>
ScheduleId: schedulerState.ScheduleId,
186
>
LastProcessedTime: lastProcessedTime,
187
>
BufferedStarts: bufferedStarts,
188
>
OngoingBackfills: ongoingBackfills,
189
>
LastCompletionResult: resultPayloads,
190
>
ContinuedFailure: continuedFailure,
191
>
ConflictToken: schedulerState.ConflictToken,
192
>
NeedRefresh: len(running) > 0,
193
>
}
194
>
195
>
return &schedulespb.StartScheduleArgs{
196
>
Schedule: schedule,
197
>
Info: info,
198
>
State: state,
199
>
}
200
}
201