feat: fix lint

Author: Przemyslaw Stepien

internal/servers/plugin/v3/plugin.go

@@ -260,16 +260,15 @@ func (s *Server) Sync(req *pb.Sync_Request, stream pb.Plugin_SyncServer) error {
 				},
 			}
 		case *message.SyncError:
-			if req.WithErrorMessages {
-				pbMsg.Message = &pb.Sync_Response_Error{
-					Error: &pb.Sync_MessageError{
-						TableName: m.TableName,
-						Error:     m.Error,
-					},
-				}
-			} else {
+			if !req.WithErrorMessages {
 				continue
 			}
+			pbMsg.Message = &pb.Sync_Response_Error{
+				Error: &pb.Sync_MessageError{
+					TableName: m.TableName,
+					Error:     m.Error,
+				},
+			}
 		default:
 			return status.Errorf(codes.Internal, "unknown message type: %T", msg)
 		}

scheduler/queue/scheduler_test.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"testing"
 
+	"github.com/cloudquery/plugin-sdk/v4/message"
 	"github.com/cloudquery/plugin-sdk/v4/scheduler/metrics"
 	"github.com/cloudquery/plugin-sdk/v4/schema"
 	"github.com/cloudquery/plugin-sdk/v4/transformers"
@@ -83,9 +84,10 @@ func TestScheduler(t *testing.T) {
 	}
 
 	resolvedResources := make(chan *schema.Resource)
+	msgs := make(chan message.SyncMessage, 10)
 	go func() {
 		defer close(resolvedResources)
-		scheduler.Sync(context.Background(), tableClients, resolvedResources)
+		scheduler.Sync(context.Background(), tableClients, resolvedResources, msgs)
 	}()
 
 	gotResources := make([]*schema.Resource, 0)