974
assertFn := func(currentRow *sqlplugin.CurrentExecutionsRow) error {
975
if !bytes.Equal(currentRow.RunID, previousRunID) {
976
>
executionState, err := workflowExecutionStateFromCurrentExecutionsRow(serializer, currentRow)
execution_util.go
977
>
if err != nil {
978
return err
979
}
980
982
>
Msg: fmt.Sprintf(
983
>
"assertRunIDAndUpdateCurrentExecution failed. current run ID: %v, request run ID: %v",
984
>
currentRow.RunID,
985
>
previousRunID,
986
>
),
987
>
RequestIDs: executionState.RequestIds,
988
>
RunID: currentRow.RunID.String(),
989
>
FirstExecutionRunID: executionState.FirstExecutionRunId,
990
>
State: currentRow.State,
991
>
Status: currentRow.Status,
992
>
LastWriteVersion: currentRow.LastWriteVersion,
993
>
StartTime: currentRow.StartTime,
994
>
}
995
}
996
return nil