Merge pull request #260 from porter-dev/beta.3.redis-init-fix

update global stream redis init

internal/kubernetes/provisioner/global_stream.go

@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"regexp"
+	"strings"
 
 	"github.com/aws/aws-sdk-go/service/ecr"
 	"github.com/porter-dev/porter/internal/repository"
@@ -49,16 +50,14 @@ func InitGlobalStream(client *redis.Client) error {
 		GlobalStreamName,
 	).Result()
 
-	fmt.Println(xInfoGroups, err)
-
-	if err != nil {
+	// if error is not NOGROUP error, return
+	if err != nil && !strings.Contains(err.Error(), "NOGROUP") {
 		return err
 	}
 
 	for _, group := range xInfoGroups {
 		// if the group exists, return with no error
 		if group.Name == GlobalStreamGroupName {
-			fmt.Println("group already exists")
 			return nil
 		}
 	}
@@ -71,8 +70,6 @@ func InitGlobalStream(client *redis.Client) error {
 		"$",
 	).Result()
 
-	fmt.Println("xgroup created", err)
-
 	return err
 }