70
}
71
73
>
shardID := rand.Int31()
74
>
namespaceID := primitives.NewUUID()
75
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
76
>
runID := primitives.NewUUID()
77
>
78
>
childWorkflow1 := s.newRandomExecutionChildWorkflowRow(shardID, namespaceID, workflowID, runID, rand.Int63())
79
>
childWorkflow2 := s.newRandomExecutionChildWorkflowRow(shardID, namespaceID, workflowID, runID, rand.Int63())
80
>
result, err := s.store.ReplaceIntoChildExecutionInfoMaps(newExecutionContext(), []sqlplugin.ChildExecutionInfoMapsRow{childWorkflow1, childWorkflow2})
81
>
s.NoError(err)
82
>
rowsAffected, err := result.RowsAffected()
83
>
s.NoError(err)
84
>
s.Equal(2, int(rowsAffected))
85
>
}
86
87
func (s *historyExecutionChildWorkflowSuite) TestReplaceSelect_Single() {