From 0d8b2b26e06b8280d3b9eb622b6eab3c2f2adf4e Mon Sep 17 00:00:00 2001
From: "al.krylov" <al.krylov@vk.team>
Date: Wed, 13 Aug 2025 18:34:13 +0300
Subject: [PATCH] NOTASK: disable triggers on replicas

---
 queue/abstract.lua | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/queue/abstract.lua b/queue/abstract.lua
index 9c2d434..5ba94aa 100644
--- a/queue/abstract.lua
+++ b/queue/abstract.lua
@@ -479,6 +479,11 @@ end
 
 --- Release all session tasks.
 local function release_session_tasks(session_uuid)
+    -- Early exit for replicas
+    if queue_state.get() ~= queue_state.states.RUNNING then
+        return
+    end
+
     local taken_tasks = box.space._queue_taken_2.index.uuid:select{session_uuid}
 
     for _, task in pairs(taken_tasks) do
@@ -500,6 +505,11 @@ function method.state()
 end
 
 function method._on_consumer_disconnect()
+    -- Early exit for replicas
+    if queue_state.get() ~= queue_state.states.RUNNING then
+        return
+    end
+
     local conn_id = connection.id()
 
     -- wakeup all waiters