Implement queue length for redis

soedinglab · Aug 16, 2023 · f718be0 · f718be0
1 parent fcf22db
commit f718be0
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/backend/jobsystem.go b/backend/jobsystem.go
@@ -384,7 +384,11 @@ func (j *RedisJobSystem) Dequeue() (*Ticket, error) {
 }
 
 func (j *RedisJobSystem) QueueLength() (int, error) {
-	return 0, errors.New("not implemented")
+	length, err := j.Client.ZCount("mmseqs:pending", "-inf", "+inf").Result()
+	if err != nil {
+		return 0, err
+	}
+	return int(length), nil
 }
 
 type LocalJobSystem struct {