BUGFIX: comment out stale key check from startup process (#42)

gojek · Apr 4, 2017 · bccd9e7 · bccd9e7
1 parent e59a139
commit bccd9e7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git 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
@@ -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()