fix: Ignore context cancelled errors.

marianogappa · marianogappa · commit 0f3beae253e8 · 2025-03-07T10:42:58.000+04:00
diff --git a/internal/servers/plugin/v3/plugin.go b/internal/servers/plugin/v3/plugin.go
@@ -456,6 +456,10 @@ func (s *Server) Transform(stream pb.Plugin_TransformServer) error {
 			}
 			if err != nil {
 				close(recvRecords)
+				if errors.Is(err, context.Canceled) {
+					// Ignore context cancellation errors
+					return nil
+				}
 				return status.Errorf(codes.Internal, "Error receiving request: %v", err)
 			}
 			record, err := pb.NewRecordFromBytes(req.Record)

Original file line number	Diff line number	Diff line change
`@@ -456,6 +456,10 @@ func (s *Server) Transform(stream pb.Plugin_TransformServer) error {`
`456`	`456`	`}`
`457`	`457`	`if err != nil {`
`458`	`458`	`close(recvRecords)`
	`459`	`+ if errors.Is(err, context.Canceled) {`
	`460`	`+ // Ignore context cancellation errors`
	`461`	`+ return nil`
	`462`	`+ }`
`459`	`463`	`return status.Errorf(codes.Internal, "Error receiving request: %v", err)`
`460`	`464`	`}`
`461`	`465`	`record, err := pb.NewRecordFromBytes(req.Record)`