66
}
67
69
>
shardID := rand.Int31()
70
>
namespaceID := primitives.NewUUID()
71
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
72
>
runID := primitives.NewUUID()
73
>
74
>
signalRequest1 := s.newRandomExecutionSignalRequestRow(shardID, namespaceID, workflowID, runID, shuffle.String(testHistoryExecutionSignalID))
75
>
signalRequest2 := s.newRandomExecutionSignalRequestRow(shardID, namespaceID, workflowID, runID, shuffle.String(testHistoryExecutionSignalID))
76
>
result, err := s.store.ReplaceIntoSignalsRequestedSets(newExecutionContext(), []sqlplugin.SignalsRequestedSetsRow{signalRequest1, signalRequest2})
77
>
s.NoError(err)
78
>
rowsAffected, err := result.RowsAffected()
79
>
s.NoError(err)
80
>
s.Equal(2, int(rowsAffected))
81
>
}
82
83
func (s *historyExecutionSignalRequestSuite) TestReplaceSelect_Single() {