From bccd9e78ad231cfbaf4d8dcf2a39d4cb184d1e6d Mon Sep 17 00:00:00 2001 From: Shaun Dunning Date: Tue, 4 Apr 2017 13:54:10 -0400 Subject: [PATCH] BUGFIX: comment out stale key check from startup process (#42) --- redis.go | 1 + worker_pool.go | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/redis.go b/redis.go index 68e49f94..934ded0a 100644 --- a/redis.go +++ b/redis.go @@ -349,6 +349,7 @@ var redisRemoveStaleKeys = fmt.Sprintf(` -- getConcurrencyKey will be inserted below %s +-- TODO: need something more efficient than KEYS cmd local function isInProgress(jobQueue) return redis.call('keys', jobQueue .. ':*:inprogress') end diff --git a/worker_pool.go b/worker_pool.go index 2503901f..a0f89069 100644 --- a/worker_pool.go +++ b/worker_pool.go @@ -174,7 +174,8 @@ func (wp *WorkerPool) Start() { } wp.started = true - wp.removeStaleKeys() + // TODO: need to fix Lua script to remove stale keys + // wp.removeStaleKeys() wp.writeConcurrencyControlsToRedis() go wp.writeKnownJobsToRedis()