fix queue query

hatchet-dev · Aug 8, 2024 · d4247b2 · d4247b2
1 parent 89769ab
commit d4247b2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/repository/prisma/dbsqlc/batch.go b/pkg/repository/prisma/dbsqlc/batch.go
diff --git a/pkg/repository/prisma/dbsqlc/queue.sql b/pkg/repository/prisma/dbsqlc/queue.sql
@@ -54,7 +54,7 @@ WHERE
     AND qi."queue" = @queue::text
     AND (
         sqlc.narg('gtId')::bigint IS NULL OR
-        qi."id" > sqlc.narg('gtId')::bigint
+        qi."id" >= sqlc.narg('gtId')::bigint
     )
 ORDER BY
     qi."id" ASC