206
mutableState, err := executionContext.LoadMutableState(ctx, r.shardContext)
207
if err != nil {
209
>
// this can happen if the workflow start event and this sync activity task are out of order
210
>
// or the target workflow is long gone
211
>
// the safe solution to this is to throw away the sync activity task
212
>
// or otherwise, worker attempt will exceed limit and put this message to DLQ
213
>
214
>
// TODO: this should return serviceerrors.NewRetryReplication to trigger a resend
215
>
// resend logic will handle not found case and drop the task.
216
>
return nil
217
>
}
218
return err
219
}