diff --git a/webmagic-extension/src/main/java/us/codecraft/webmagic/scheduler/RedisScheduler.java b/webmagic-extension/src/main/java/us/codecraft/webmagic/scheduler/RedisScheduler.java index bbb945c0..1de718a8 100644 --- a/webmagic-extension/src/main/java/us/codecraft/webmagic/scheduler/RedisScheduler.java +++ b/webmagic-extension/src/main/java/us/codecraft/webmagic/scheduler/RedisScheduler.java @@ -119,7 +119,7 @@ public class RedisScheduler extends DuplicateRemovedScheduler implements Monitor public int getTotalRequestsCount(Task task) { Jedis jedis = pool.getResource(); try { - Long size = jedis.scard(getQueueKey(task)); + Long size = jedis.scard(getSetKey(task)); return size.intValue(); } finally { pool.returnResource(jedis);