Skip to content

Commit

Permalink
Merge pull request #49 from milanbhagwat/master
Browse files Browse the repository at this point in the history
Updating consuming code after func renaming
  • Loading branch information
vijaynalawade authored Jun 13, 2022
2 parents 2385f65 + da7dc4e commit 93b16e5
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions flow-state/server/rest/endpoints.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ func AppendEndpoints(router *httprouter.Router, logger log.Logger, exposeRecorde
router.POST("/v1/instances/end", sm.saveEnd)
}
// start saveStep worker go routines
maxOpenConn := sm.stepStore.GetMaxOpenConn()
maxOpenConn := sm.stepStore.MaxConcurrencyLimit()
for i := 0; i < maxOpenConn; i++ {
go saveStepWorker(sm)
}
Expand All @@ -98,7 +98,7 @@ func (se *ServiceEndpoints) getHealthCheck(response http.ResponseWriter, request
se.logger.Debugf("Endpoint[GET:/health] : Called")
switch request.Method {
case http.MethodGet:
if se.stepStore.GetDBPingStatus() {
if se.stepStore.Status() {
response.WriteHeader(http.StatusOK)
} else {
se.logger.Info("Health check status failed")
Expand Down

0 comments on commit 93b16e5

Please sign in to comment.