389
func (a *activities) MigrateScheduleToChasm(ctx context.Context, req *schedulerpb.CreateFromMigrationStateRequest) error {
390
if req.GetNamespaceId() != a.namespaceID.String() {
391
>
return temporal.NewNonRetryableApplicationError(
activities.go
392
>
fmt.Sprintf("MigrateScheduleToChasm: request namespace ID %q does not match activity namespace ID %q", req.GetNamespaceId(), a.namespaceID),
393
>
"namespace_mismatch",
394
>
nil,
395
>
)
396
>
}
397
_, err := a.SchedulerClient.CreateFromMigrationState(ctx, req)
398
if err != nil {