Skip to content

Commit 4bf07e1

Browse files
committed
fix: disable worker
1 parent 0be69a9 commit 4bf07e1

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/api.js

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -124,11 +124,11 @@ export class Api {
124124
addMessage: redis.defineScript({
125125
NUMBER_OF_KEYS: 1,
126126
SCRIPT: `
127-
if redis.call("EXISTS", KEYS[1]) == 0 then
128-
redis.call("XADD", "${this.redisWorkerStreamName}", "*", "compact", KEYS[1])
129-
elseif redis.call("XLEN", KEYS[1]) > 100 then
130-
redis.call("SADD", "${this.prefix}:worker:checklist", KEYS[1])
131-
end
127+
-- if redis.call("EXISTS", KEYS[1]) == 0 then
128+
-- redis.call("XADD", "${this.redisWorkerStreamName}", "*", "compact", KEYS[1])
129+
-- elseif redis.call("XLEN", KEYS[1]) > 100 then
130+
-- redis.call("SADD", "${this.prefix}:worker:checklist", KEYS[1])
131+
-- end
132132
redis.call("XADD", KEYS[1], "*", "m", ARGV[1])
133133
`,
134134
/**

0 commit comments

Comments
 (0)