Skip to content

Commit

Permalink
RedisBroker: Leave existing max_concurrency values alone
Browse files Browse the repository at this point in the history
Leave already-set concurrency values alone, always.

Fixes: Issue #27
  • Loading branch information
nisimond committed Feb 28, 2024
1 parent 96451a9 commit fdfcfd5
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions spinach/brokers/redis_scripts/set_concurrency_keys.lua
Original file line number Diff line number Diff line change
Expand Up @@ -19,11 +19,10 @@ for i=3, #ARGV do
if max_concurrency ~= -1 then
new_task_names[task["name"]] = true

-- Override max_concurrency whatever it is already set to, if
-- anything.
redis.call('hset', max_concurrency_key, task["name"], max_concurrency)
-- Check to see if current_concurrency exists before initialising
-- it.
-- Check to see if concurrency keys exist before initialising them.
if redis.call('hexists', current_concurrency_key, task["name"]) == 0 then
redis.call('hset', max_concurrency_key, task["name"], max_concurrency)
end
if redis.call('hexists', current_concurrency_key, task["name"]) == 0 then
redis.call('hset', current_concurrency_key, task["name"], 0)
end
Expand Down

0 comments on commit fdfcfd5

Please sign in to comment.