Merge pull request #3152 from cliveseldon/3139_feedback

remove aggregate from feedback
SeldonIO · May 13, 2021 · 1b1580b · 1b1580b
2 parents c4f5b5c + 71ca888
commit 1b1580b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/executor/predictor/predictor_process.go b/executor/predictor/predictor_process.go
@@ -309,7 +309,8 @@ func (p *PredictorProcess) feedbackChildren(node *v1.PredictiveUnit, msg payload
 				return cmsgs[0], err
 			}
 		}
-		return p.aggregate(node, cmsgs)
+		// Arbitrary return of first feedback
+		return cmsgs[0], nil
 	} else {
 		return msg, nil
 	}