was using the global cluster scenario instead of the argument

Author: ndyakov

osscluster_test.go

@@ -87,7 +87,7 @@ func (s *clusterScenario) newClusterClient(
 }
 
 func (s *clusterScenario) Close() error {
-
+	ctx := context.TODO()
 	for _, master := range s.masters() {
 		err := master.FlushAll(ctx).Err()
 		if err != nil {
@@ -103,15 +103,18 @@ func (s *clusterScenario) Close() error {
 
 	for _, port := range s.ports {
 		if process, ok := processes[port]; ok {
-			process.Close()
+			if process != nil {
+				process.Close()
+			}
+
 			delete(processes, port)
 		}
 	}
+
 	return nil
 }
 
 func configureClusterTopology(ctx context.Context, scenario *clusterScenario) error {
-	fmt.Println("Configuring cluster topology, please wait...")
 	err := collectNodeInformation(ctx, scenario)
 	if err != nil {
 		return err
@@ -233,7 +236,7 @@ func startCluster(ctx context.Context, scenario *clusterScenario) error {
 		scenario.processes[port] = process
 	}
 
-	return configureClusterTopology(ctx, cluster)
+	return configureClusterTopology(ctx, scenario)
 }
 
 func assertSlotsEqual(slots, wanted []redis.ClusterSlot) error {