1038
}
1039
if bytes.Equal(currentRow.RunID, requestRunID) {
1040
>
executionState, err := workflowExecutionStateFromCurrentExecutionsRow(serializer, currentRow)
execution_util.go
1041
>
if err != nil {
1042
return err
1043
}
1045
>
Msg: fmt.Sprintf(
1046
>
"assertRunIDMismatch failed. request run ID: %v, current run ID: %v",
1047
>
requestRunID,
1048
>
currentRow.RunID.String(),
1049
>
),
1050
>
RequestIDs: executionState.RequestIds,
1051
>
RunID: currentRow.RunID.String(),
1052
>
FirstExecutionRunID: executionState.FirstExecutionRunId,
1053
>
State: currentRow.State,
1054
>
Status: currentRow.Status,
1055
>
LastWriteVersion: currentRow.LastWriteVersion,
1056
>
StartTime: currentRow.StartTime,
1057
>
}
1058
}
1059
return nil