Skip to content
Snippets Groups Projects
Commit d3b34d1f authored by Leonardo Christino's avatar Leonardo Christino
Browse files

Re-enable machine learning backend

parent 8428f0ca
No related branches found
No related tags found
No related merge requests found
Pipeline #126921 failed
......@@ -142,12 +142,16 @@ func (s *Service) handleMessageHelper(msg *broker.Message, sessionID, clientID,
queueName := ""
switch ml.Type {
case "centrality":
log.Debug().Msg("centrality")
queueName = "ctr_queue"
case "linkPrediction":
log.Debug().Msg("link prediction")
queueName = "lpr_queue"
case "communityDetection":
log.Debug().Msg("community detection")
queueName = "cdt_queue"
case "shortestPath":
log.Debug().Msg("shortest path")
queueName = "stp_queue"
default:
log.Warn().Str("Name", ml.Type).Msg("unknown ML queue, ignoring")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment