diff --git a/internal/document/service.go b/internal/document/service.go
index 9ba30df3..bc4c27cb 100644
--- a/internal/document/service.go
+++ b/internal/document/service.go
@@ -41,7 +41,8 @@ func (s *Service) Sync(ctx context.Context, doc Document) error {
 		return err
 	}
 
-	results, err := s.db.ListResultsByDocumentID(ctx, docID)
+	// TODO grab only the results with the latest clean and text version
+	results, err := s.db.ListResultsByDocumentID(ctx, docID, minCleanVersion, minTextVersion)
 	if err != nil {
 		return err
 	}
@@ -49,10 +50,12 @@ func (s *Service) Sync(ctx context.Context, doc Document) error {
 	for _, query := range queries {
 		isSynced := false
 		for _, result := range results {
-			if result.Queryid != query.ID {
+			if result.Queryid != query.ID && result.Queryversion != query.Queryversion {
 				continue
 			}
-			isSynced = result.Cleanversion >= query.Mincleanversion && result.Textversion >= query.Mintextversion && result.Queryversion != query.Queryversion
+			if result.Cleanversion > query.Mincleanversion && result.Textversion > query.Mintextversion {
+				isSynced = true
+			}
 			break
 		}
 		if isSynced {