@@ -184,7 +184,7 @@ func compareJSONConfigs(t *testing.T, gotJSON, wantJSON string) {
184184// Test verifies that if an RPC is in flight, the old cluster remains in
185185// the service config until the stream is committed.
186186func (s ) TestResolverDelayedOnCommitted (t * testing.T ) {
187- testFilterTypeURL := "type.googleapis.com/test.delayingFilter-"
187+ testFilterTypeURL := "type.googleapis.com/test.delayingFilter-" + uuid . New (). String ()
188188 blockChan , enteredChan := make (chan struct {}), make (chan struct {})
189189 tb := & testFilterBuilder {
190190 typeURL : testFilterTypeURL ,
@@ -362,10 +362,8 @@ func (s) TestResolverDelayedOnCommitted(t *testing.T) {
362362// executed. This decrements the cluster reference count to 0, allowing the
363363// resolver to unsubscribe and prune the old cluster from the service config.
364364func (s ) TestResolverPrunesCluster_StreamCreationFailure (t * testing.T ) {
365- const (
366- testFilterTypeURL = "type.googleapis.com/test.blockingFilter"
367- wantErr = "blocking filter error"
368- )
365+ testFilterTypeURL := "type.googleapis.com/test.blockingFilter" + uuid .New ().String ()
366+ const wantErr = "blocking filter error"
369367 blockChan , enteredChan := make (chan struct {}), make (chan struct {})
370368 tb := & testFilterBuilder {
371369 typeURL : testFilterTypeURL ,
0 commit comments