51
}
52
54
>
shardID := rand.Int31()
55
>
namespaceID := primitives.NewUUID()
56
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
57
>
runID := primitives.NewUUID()
58
>
signalID := shuffle.String(testHistoryExecutionSignalID)
59
>
60
>
signalRequest := s.newRandomExecutionSignalRequestRow(shardID, namespaceID, workflowID, runID, signalID)
61
>
result, err := s.store.ReplaceIntoSignalsRequestedSets(newExecutionContext(), []sqlplugin.SignalsRequestedSetsRow{signalRequest})
62
>
s.NoError(err)
63
>
rowsAffected, err := result.RowsAffected()
64
>
s.NoError(err)
65
>
s.Equal(1, int(rowsAffected))
66
>
}
67
68
func (s *historyExecutionSignalRequestSuite) TestReplace_Multiple() {