Update error message for consistency & format long line

SeldonIO · Aug 10, 2023 · c09abdd · c09abdd
1 parent 06fe5b1
commit c09abdd
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/scheduler/pkg/kafka/dataflow/server.go b/scheduler/pkg/kafka/dataflow/server.go
@@ -341,7 +341,14 @@ func (c *ChainerServer) rebalance() {
 		}
 		c.mu.Lock()
 		if len(c.streams) == 0 {
-			if err := c.pipelineHandler.SetPipelineState(pv.Name, pv.Version, pv.UID, pipeline.PipelineCreate, "No servers available", sourceChainerServer); err != nil {
+			if err := c.pipelineHandler.SetPipelineState(
+				pv.Name,
+				pv.Version,
+				pv.UID,
+				pipeline.PipelineCreate,
+				"no dataflow engines available to handle pipeline",
+				sourceChainerServer,
+			); err != nil {
 				logger.WithError(err).Errorf("Failed to set pipeline state to creating for %s", pv.String())
 			}
 		} else {