try without pgrowlocks

Author: brontolosone

lib/model/query/blobs.js

@@ -32,19 +32,32 @@ const getById = (blobId) => ({ maybeOne }) =>
     .then(map(construct(Blob)));
 
 const s3CountByStatus = (status) => ({ oneFirst }) => {
+  const lockCTEs = sql`
+    notlockeds AS (
+        SELECT 1 FROM blobs FOR UPDATE SKIP LOCKED
+    ),
+    locked AS (
+        SELECT (
+            (SELECT count(id) FROM blobs)
+            -
+            (SELECT count(*) FROM notlockeds)
+        ) as count
+    )`;
   // in_progress is an implicit status
   if (status === 'in_progress') {
-    return oneFirst(sql`SELECT COUNT(*) FROM PGROWLOCKS('blobs')`);
+    return oneFirst(sql`
+      WITH ${lockCTEs}
+      SELECT count FROM locked`
+    );
+    // return oneFirst(sql`SELECT COUNT(*) FROM PGROWLOCKS('blobs')`);
   } else if (status === 'pending') {
     return oneFirst(sql`
       WITH
         allpending AS (
           SELECT COUNT(*) FROM blobs WHERE s3_status='pending'
         ),
-        locked AS (
-          SELECT COUNT(*) FROM PGROWLOCKS('blobs')
-        )
-      SELECT allpending.count-locked.count FROM allpending, locked
+        ${lockCTEs}
+        SELECT allpending.count-locked.count FROM allpending, locked
     `);
   } else {
     return oneFirst(sql`SELECT COUNT(*) FROM blobs WHERE s3_status=${status}`);