diff --git a/cmd/apollo-scheduler/main.go b/cmd/apollo-scheduler/main.go index f6abf5c..ee439e3 100644 --- a/cmd/apollo-scheduler/main.go +++ b/cmd/apollo-scheduler/main.go @@ -197,9 +197,9 @@ func enqueueAccounts(ctx context.Context, logger *logrus.Logger, statsd *statsd. for i=1, #ids do local key = "locks:accounts:" .. ids[i] if redis.call("exists", key) == 0 then + redis.call("setex", key, 60, 1) retv[#retv + 1] = ids[i] end - redis.call("setex", key, 60, 1) end return retv