Browse Source

add support for tagged observer: fix

Shelikhoo 4 years ago
parent
commit
1de2466c60
1 changed files with 3 additions and 3 deletions
  1. 3 3
      app/observatory/command/command.go

+ 3 - 3
app/observatory/command/command.go

@@ -30,13 +30,13 @@ func (s *service) GetOutboundStatus(ctx context.Context, request *GetOutboundSta
 	if request.Tag == "" {
 		observeResult, err := s.observatory.GetObservation(ctx)
 		if err != nil {
-			newError("cannot get observation").Base(err)
+			return nil, newError("cannot get observation").Base(err)
 		}
 		result = observeResult
 	} else {
-		observeResult, err := common.Must2(s.observatory.(features.TaggedFeatures).GetFeaturesByTag(request.Tag)).(extension.Observatory).GetObservation(s.ctx)
+		observeResult, err := common.Must2(s.observatory.(features.TaggedFeatures).GetFeaturesByTag(request.Tag)).(extension.Observatory).GetObservation(ctx)
 		if err != nil {
-			newError("cannot get observation").Base(err)
+			return nil, newError("cannot get observation").Base(err)
 		}
 		result = observeResult
 	}