From c349cf907a253479c74cfd25eba64e37cea8c047 Mon Sep 17 00:00:00 2001 From: mayuehit Date: Fri, 28 Nov 2025 16:50:05 +0800 Subject: [PATCH 1/2] fix kill instance --- api/python/yr/fnruntime.pyx | 4 +++- src/libruntime/fsclient/fs_intf.cpp | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/api/python/yr/fnruntime.pyx b/api/python/yr/fnruntime.pyx index 712f117..78b2090 100644 --- a/api/python/yr/fnruntime.pyx +++ b/api/python/yr/fnruntime.pyx @@ -2505,7 +2505,7 @@ cdef class Fnruntime: def get_instance_by_name(self, name, ns, timeout): cdef: pair[CFunctionMeta, CErrorInfo] ret - string cinstanceID = (ns + "-" + name if ns else name).encode() + string cinstanceID int sigNo = CSignal.KILLINSTANCESYNC string cname = name.encode() string cns = ns.encode() @@ -2513,6 +2513,8 @@ cdef class Fnruntime: cdef shared_ptr[CLibruntime] c_libruntime = CLibruntimeManager.Instance().GetLibRuntime() if c_libruntime == nullptr: raise RuntimeError("already finalized") + yr_ns = get_namespace() + cinstanceID = (ns + "-" + name if ns else yr_ns + "-" + name).encode() with nogil: c_libruntime.get().SetTenantIdWithPriority() ret = c_libruntime.get().GetInstance(cname, cns, ctimeout) diff --git a/src/libruntime/fsclient/fs_intf.cpp b/src/libruntime/fsclient/fs_intf.cpp index f21d530..529cfaa 100644 --- a/src/libruntime/fsclient/fs_intf.cpp +++ b/src/libruntime/fsclient/fs_intf.cpp @@ -193,7 +193,7 @@ void FSIntf::HandleCheckpointRequest(const CheckpointRequest &req, CheckpointCal if (ExistProcessingRequestId()) { CheckpointResponse resp; resp.set_code(common::ERR_INNER_SYSTEM_ERROR); - resp.set_message("exit processing request"); + resp.set_message("exist processing request, checkpoint error"); callback(resp); return; } -- Gitee From b3bc89fbbd922b209cf0d80e82d30914bef47b61 Mon Sep 17 00:00:00 2001 From: mayuehit Date: Fri, 28 Nov 2025 17:13:15 +0800 Subject: [PATCH 2/2] fix --- api/python/yr/fnruntime.pyx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/api/python/yr/fnruntime.pyx b/api/python/yr/fnruntime.pyx index 78b2090..4c534b1 100644 --- a/api/python/yr/fnruntime.pyx +++ b/api/python/yr/fnruntime.pyx @@ -2513,7 +2513,7 @@ cdef class Fnruntime: cdef shared_ptr[CLibruntime] c_libruntime = CLibruntimeManager.Instance().GetLibRuntime() if c_libruntime == nullptr: raise RuntimeError("already finalized") - yr_ns = get_namespace() + yr_ns = self.get_namespace() cinstanceID = (ns + "-" + name if ns else yr_ns + "-" + name).encode() with nogil: c_libruntime.get().SetTenantIdWithPriority() -- Gitee