updated stageTime-server 24.0220.1529 for tag version v0.4.57

server.go

@@ -125,8 +125,6 @@ func (s StatusService) GetStatus(ctx context.Context, gRPCRequest *revisionrun.S
 
 func (s Server) CreateRevisionRun(ctx context.Context, gRPCRequest *revisionrun.CreateRevisionRunRequest) (*revisionrun.Response, error) {
 
-	prInformation := make(map[string]string)
-
 	// CREATE REDIS CLIENT / JSON HANDLER
 	redisJSONHandler.SetGoRedisClient(redisClient)
 
@@ -156,12 +154,15 @@ func (s Server) CreateRevisionRun(ctx context.Context, gRPCRequest *revisionrun.
 
 	// LOOP OVER REVISIONRUN
 	stages := make(map[string]int)
+	stageNumber := 0
 	for i := 0; i < (len(renderedPipelineruns)); i++ {
 
 		countPipelineRuns = 0
 
 		for _, pr := range renderedPipelineruns[i] {
 
+			prInformation := make(map[string]string)
+
 			prValid, prInformation := internal.ValidateStorePipelineRuns(pr)
 
 			if !prValid {
@@ -207,12 +208,7 @@ func (s Server) CreateRevisionRun(ctx context.Context, gRPCRequest *revisionrun.
 
 	}
 
-	countStage := sthingsBase.ConvertStringToInteger(prInformation["stage"]) + 1
-
-	// CHECK IF REVISIONRUN ALREADY EXISTS
-	revisionRunFromRedis := server.GetRevisionRunFromRedis(redisJSONHandler, revisionRunID+"-status", true)
-	fmt.Println(revisionRunFromRedis)
-	fmt.Println("EXISTS ALREADY")
+	countStage := stageNumber + 1
 
 	// CREATE REVISIONRUN STATUS ON REDIS + PRINT AS TABLE
 	initialRrs := server.RevisionRunStatus{

server/producing.go

@@ -80,6 +80,7 @@ func GetRevisionRunFromRedis(redisJSONHandler *rejson.Handler, revisionRunStatus
 	revisionRunStatus, jsonExists := sthingsCli.GetRedisJSON(redisJSONHandler, revisionRunStatusID)
 
 	if jsonExists {
+
 		err := json.Unmarshal(revisionRunStatus, &revisionRunFromRedis)
 		if err != nil {
 			log.Fatalf("FAILED TO JSON UNMARSHAL REVISIONRUN STATUS")