Skip to content

Commit

Permalink
updated stageTime-server 24.0220.1550 for tag version v0.4.59
Browse files Browse the repository at this point in the history
  • Loading branch information
patrick-hermann-sva committed Feb 20, 2024
1 parent bed62f8 commit 9cb8a6f
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions server.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ var (
redisClient = sthingsCli.CreateRedisClient(redisAddress+":"+redisPort, redisPassword)
redisJSONHandler = rejson.NewReJSONHandler()
countPipelineRuns = 0
pipelineRunStatus []server.PipelineRunStatus
)

type Server struct {
Expand Down Expand Up @@ -138,8 +139,6 @@ func (s Server) CreateRevisionRun(ctx context.Context, gRPCRequest *revisionrun.

log.Println("INCOMING gRPC REQUEST:", receivedRevisionRun.String())

var pipelineRunStatus []server.PipelineRunStatus

if err := json.Unmarshal([]byte(receivedRevisionRun.Bytes()), &gRPCRequest); err != nil {
log.Fatal(err)
}
Expand All @@ -159,6 +158,7 @@ func (s Server) CreateRevisionRun(ctx context.Context, gRPCRequest *revisionrun.
stageNumber := 0
for i := 0; i < (len(renderedPipelineruns)); i++ {

pipelineRunStatus = nil
countPipelineRuns = 0

for _, pr := range renderedPipelineruns[i] {
Expand Down Expand Up @@ -223,6 +223,8 @@ func (s Server) CreateRevisionRun(ctx context.Context, gRPCRequest *revisionrun.
log.Info("INITIAL REVISIONRUNSTATUS WAS ADDED TO REDIS (JSON): ", revisionRunID+"-status")

// CREATE PIPELINERUN STATUS ON REDIS + PRINT AS TABLE
fmt.Println("STATUS", pipelineRunStatus)

for _, pr := range pipelineRunStatus {
sthingsCli.SetRedisJSON(redisJSONHandler, pr, pr.PipelineRunName+"-status")
log.Info("INITIAL PIPELINERUN STATUS WAS ADDED TO REDIS (JSON): ", pr.PipelineRunName+"-status")
Expand Down

0 comments on commit 9cb8a6f

Please sign in to comment.