224
}
225
226
>
func (h *handler) MigrateToWorkflow(ctx context.Context, req *schedulerpb.MigrateToWorkflowRequest) (resp *schedulerpb.MigrateToWorkflowResponse, err error) {
handler.go
227
>
defer log.CapturePanic(h.logger, &err)
228
>
229
>
resp, _, err = chasm.UpdateComponent(
230
>
ctx,
231
>
chasm.NewComponentRef[*Scheduler](
232
>
chasm.ExecutionKey{
233
>
NamespaceID: req.NamespaceId,
234
>
BusinessID: req.ScheduleId,
235
>
},
236
>
),
237
>
(*Scheduler).MigrateToWorkflow,
238
>
req,
239
>
)
240
>
if errors.Is(err, ErrSentinel) {
241
>
return nil, ErrSentinelBlocked
242
>
}
243
return resp, err
244
}