71
}
72
74
>
shardID := rand.Int31()
75
>
namespaceID := primitives.NewUUID()
76
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
77
>
runID := primitives.NewUUID()
78
>
79
>
timer1 := s.newRandomExecutionTimerRow(shardID, namespaceID, workflowID, runID, shuffle.String(testHistoryExecutionTimerID))
80
>
timer2 := s.newRandomExecutionTimerRow(shardID, namespaceID, workflowID, runID, shuffle.String(testHistoryExecutionTimerID))
81
>
result, err := s.store.ReplaceIntoTimerInfoMaps(newExecutionContext(), []sqlplugin.TimerInfoMapsRow{timer1, timer2})
82
>
s.NoError(err)
83
>
rowsAffected, err := result.RowsAffected()
84
>
s.NoError(err)
85
>
s.Equal(2, int(rowsAffected))
86
>
}
87
88
func (s *historyExecutionTimerSuite) TestReplaceSelect_Single() {