From c9cab0843e231f6cd7ded59a52f4f396b2cf2828 Mon Sep 17 00:00:00 2001 From: atauov Date: Tue, 28 Apr 2026 15:17:33 +0500 Subject: [PATCH] in passive node requests reject immediately --- statefun/function_type.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/statefun/function_type.go b/statefun/function_type.go index 7c329c09..f50ea799 100644 --- a/statefun/function_type.go +++ b/statefun/function_type.go @@ -393,6 +393,9 @@ func (ft *FunctionType) handleMsgForID(id string, msg FunctionTypeMsg, typenameI if msg.AckCallback != nil { msg.AckCallback(true) // we dont want to redeliver this } + if msg.RefusalCallback != nil { + msg.RefusalCallback(true) // request will close immediately + } lg.Logf(lg.DebugLevel, sendMsgFuncErrorMsg, ft.name, id, "runtime is passive") return }