CovenantSQL
diff --git a/‎worker/dbms_mux.go‎
Lines changed: 2 additions & 2 deletions b/‎worker/dbms_mux.go‎
Lines changed: 2 additions & 2 deletions
@@ -77,11 +77,11 @@ func (s *DBKayakMuxService) Fetch(req *kt.FetchRequest, resp *kt.FetchResponse)
 
 	if v, ok := s.serviceMap.Load(id); ok {
 		var l *kt.Log
-		if l, err = v.(*kayak.Runtime).Fetch(req.GetContext(), req.Index); err != nil {
+		if l, err = v.(*kayak.Runtime).Fetch(req.GetContext(), req.Index); err == nil {
 			resp.Log = l
 			resp.Instance = req.Instance
-			return err
 		}
+		return
 	}
 
 	return errors.Wrapf(ErrUnknownMuxRequest, "instance %v", req.Instance)
Original file line number	Diff line number	Diff line change
`@@ -77,11 +77,11 @@ func (s DBKayakMuxService) Fetch(req kt.FetchRequest, resp *kt.FetchResponse)`
`77`	`77`
`78`	`78`	`if v, ok := s.serviceMap.Load(id); ok {`
`79`	`79`	`var l *kt.Log`
`80`		`- if l, err = v.(*kayak.Runtime).Fetch(req.GetContext(), req.Index); err != nil {`
	`80`	`+ if l, err = v.(*kayak.Runtime).Fetch(req.GetContext(), req.Index); err == nil {`
`81`	`81`	`resp.Log = l`
`82`	`82`	`resp.Instance = req.Instance`
`83`		`- return err`
`84`	`83`	`}`
	`84`	`+ return`
`85`	`85`	`}`
`86`	`86`
`87`	`87`	`return errors.Wrapf(ErrUnknownMuxRequest, "instance %v", req.Instance)`