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 20492893212c39b46c9781fc7f4b536623e79246..6f6578cd4b9cf2b5db88526656f9e590692b24f3 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 f5ab1da78991cc4bb36b795d90d24151dacec10d..0f9e7f85da123a0203097dc41cb1d3c61a3ae86b 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");