731
resp, err := remoteAdminClient.SyncWorkflowState(ctx, req)
732
if err != nil {
734
>
if errors.As(err, &resourceExhaustedError) {
735
return false, serviceerror.NewInvalidArgumentf("sync workflow state failed due to resource exhausted: %v, request payload size: %v", err, req.Size())
736
}
738
>
tag.WorkflowNamespaceID(syncStateErr.NamespaceId),
739
>
tag.WorkflowID(syncStateErr.WorkflowId),
740
>
tag.WorkflowRunID(syncStateErr.RunId),
741
>
tag.ReplicationTask(e.replicationTask),
742
>
)
743
>
744
>
var workflowNotReady *serviceerror.WorkflowNotReady
745
>
if errors.As(err, &workflowNotReady) {
746
logger.Info("Dropped replication task as source mutable state has buffered events.", tag.Error(err))
747
return false, nil