From e691f508c5017ae6b3634838433cfce89dd02f7b Mon Sep 17 00:00:00 2001 From: lebreton Date: Thu, 6 Nov 2025 22:46:30 +0800 Subject: [PATCH] remove state check when returning master info --- .../local_scheduler/instance_control/instance_ctrl_actor.cpp | 1 - .../instance_control/instance_ctrl_actor_test.cpp | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/functionsystem/src/function_proxy/local_scheduler/instance_control/instance_ctrl_actor.cpp b/functionsystem/src/function_proxy/local_scheduler/instance_control/instance_ctrl_actor.cpp index 2049289..6f6578c 100644 --- a/functionsystem/src/function_proxy/local_scheduler/instance_control/instance_ctrl_actor.cpp +++ b/functionsystem/src/function_proxy/local_scheduler/instance_control/instance_ctrl_actor.cpp @@ -327,7 +327,6 @@ litebus::Future InstanceCtrlActor::Kill(const std::string &srcInst case NOTIFY_SIGNAL: { return CheckInstanceExist(srcInstanceID, killReq) .Then(litebus::Defer(GetAID(), &InstanceCtrlActor::CheckKillParam, _1, srcInstanceID, killReq)) - .Then(litebus::Defer(GetAID(), &InstanceCtrlActor::ProcessKillCtxByInstanceState, _1)) .Then(litebus::Defer(GetAID(), &InstanceCtrlActor::SignalRoute, _1)) .Then(litebus::Defer(GetAID(), &InstanceCtrlActor::SendNotificationSignal, _1, srcInstanceID, killReq, 0)); diff --git a/functionsystem/tests/unit/function_proxy/local_scheduler/instance_control/instance_ctrl_actor_test.cpp b/functionsystem/tests/unit/function_proxy/local_scheduler/instance_control/instance_ctrl_actor_test.cpp index f5ab1da..0f9e7f8 100644 --- a/functionsystem/tests/unit/function_proxy/local_scheduler/instance_control/instance_ctrl_actor_test.cpp +++ b/functionsystem/tests/unit/function_proxy/local_scheduler/instance_control/instance_ctrl_actor_test.cpp @@ -808,7 +808,7 @@ TEST_F(InstanceCtrlActorTest, CancelSchedule) */ TEST_F(InstanceCtrlActorTest, RetryNotificationSignal) { auto scheduleReq = std::make_shared(); - scheduleReq->mutable_instance()->mutable_instancestatus()->set_code(static_cast(InstanceState::RUNNING)); + scheduleReq->mutable_instance()->mutable_instancestatus()->set_code(static_cast(InstanceState::CREATING)); scheduleReq->mutable_instance()->set_functionproxyid(TEST_NODE_ID); scheduleReq->mutable_instance()->set_instanceid(SUBSCRIBER_ID); scheduleReq->set_requestid("requestId"); -- Gitee