Swallow RPC errors as they are handled by stats handler and reported …

…in reports
bojand · Feb 24, 2019 · 7cd212e · 7cd212e
1 parent 645ad20
commit 7cd212e
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/runner/requester.go b/runner/requester.go
@@ -326,17 +326,20 @@ func (b *Requester) makeRequest() error {
 		ctx = metadata.NewOutgoingContext(ctx, *reqMD)
 	}
 
+	// RPC errors are handled via stats handler
+
 	if b.mtd.IsClientStreaming() && b.mtd.IsServerStreaming() {
-		return b.makeBidiRequest(&ctx, streamInput)
+		_ = b.makeBidiRequest(&ctx, streamInput)
 	}
 	if b.mtd.IsClientStreaming() {
-		return b.makeClientStreamingRequest(&ctx, streamInput)
+		_ = b.makeClientStreamingRequest(&ctx, streamInput)
 	}
 	if b.mtd.IsServerStreaming() {
-		return b.makeServerStreamingRequest(&ctx, input)
+		_ = b.makeServerStreamingRequest(&ctx, input)
 	}
+
 	// TODO: handle response?
-	_, err = b.stub.InvokeRpc(ctx, b.mtd, input)
+	_, _ = b.stub.InvokeRpc(ctx, b.mtd, input)
 	return err
 }