fix: max lag (#1319)

Signed-off-by: jyu6 <juanlu_yu@intuit.com> (cherry picked from commit 24afc5e)
numaproj · Nov 3, 2023 · e05132e · e05132e
1 parent 6ab96b1
commit e05132e
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/server/apis/v1/handler.go b/server/apis/v1/handler.go
@@ -353,11 +353,12 @@ func (h *handler) GetPipeline(c *gin.Context) {
 		}
 	}
 	// if the data hasn't arrived the sink vertex
-	// use 0 instead of the initial watermark value -1
+	// set the lag to be -1
 	if minWM == -1 {
-		minWM = 0
+		lag = -1
+	} else {
+		lag = maxWM - minWM
 	}
-	lag = maxWM - minWM
 
 	pipelineResp := NewPipelineInfo(status, &lag, pl)
 	c.JSON(http.StatusOK, NewNumaflowAPIResponse(nil, pipelineResp))