56
}
57
59
>
shardID := rand.Int31()
60
>
namespaceID := primitives.NewUUID()
61
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
62
>
runID := primitives.NewUUID()
63
>
timerID := shuffle.String(testHistoryExecutionTimerID)
64
>
65
>
timer := s.newRandomExecutionTimerRow(shardID, namespaceID, workflowID, runID, timerID)
66
>
result, err := s.store.ReplaceIntoTimerInfoMaps(newExecutionContext(), []sqlplugin.TimerInfoMapsRow{timer})
67
>
s.NoError(err)
68
>
rowsAffected, err := result.RowsAffected()
69
>
s.NoError(err)
70
>
s.Equal(1, int(rowsAffected))
71
>
}
72
73
func (s *historyExecutionTimerSuite) TestReplace_Multiple() {