We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b144cf0 commit 0d8b2b2Copy full SHA for 0d8b2b2
queue/abstract.lua
@@ -479,6 +479,11 @@ end
479
480
--- Release all session tasks.
481
local function release_session_tasks(session_uuid)
482
+ -- Early exit for replicas
483
+ if queue_state.get() ~= queue_state.states.RUNNING then
484
+ return
485
+ end
486
+
487
local taken_tasks = box.space._queue_taken_2.index.uuid:select{session_uuid}
488
489
for _, task in pairs(taken_tasks) do
@@ -500,6 +505,11 @@ function method.state()
500
505
end
501
506
502
507
function method._on_consumer_disconnect()
508
509
510
511
512
503
513
local conn_id = connection.id()
504
514
515
-- wakeup all waiters
0 commit comments