diff --git a/Partner-Core/src/main/java/work/slhaf/partner/core/cognation/CognationCapability.java b/Partner-Core/src/main/java/work/slhaf/partner/core/cognation/CognationCapability.java
index 9dda332f..06fe7164 100644
--- a/Partner-Core/src/main/java/work/slhaf/partner/core/cognation/CognationCapability.java
+++ b/Partner-Core/src/main/java/work/slhaf/partner/core/cognation/CognationCapability.java
@@ -9,7 +9,7 @@ import java.util.concurrent.locks.Lock;
 @Capability("cognation")
 public interface CognationCapability {
 
-    String initiateTurn(String input);
+    String initiateTurn(String input, String target);
 
     List<Message> getChatMessages();
 
diff --git a/Partner-Core/src/main/java/work/slhaf/partner/core/cognation/CognationCore.java b/Partner-Core/src/main/java/work/slhaf/partner/core/cognation/CognationCore.java
index 34db08d5..5c1a149e 100644
--- a/Partner-Core/src/main/java/work/slhaf/partner/core/cognation/CognationCore.java
+++ b/Partner-Core/src/main/java/work/slhaf/partner/core/cognation/CognationCore.java
@@ -38,8 +38,9 @@ public class CognationCore extends PartnerCore<CognationCore> {
     }
 
     @CapabilityMethod
-    public String initiateTurn(String input) {
+    public String initiateTurn(String input, String target) {
         PartnerRunningFlowContext primaryContext = PartnerRunningFlowContext.Companion.fromSelf(input);
+        primaryContext.setTarget(target);
         PartnerRunningFlowContext executedContext = AgentRuntime.INSTANCE.submit(primaryContext);
         return executedContext.getCoreResponse().getString("text");
     }
diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/planner/ActionPlanner.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/planner/ActionPlanner.java
index b7d0722b..1a62781c 100644
--- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/planner/ActionPlanner.java
+++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/planner/ActionPlanner.java
@@ -201,7 +201,7 @@ public class ActionPlanner extends AbstractAgentModule.Running<PartnerRunningFlo
                 Schedulable.ScheduleType.ONCE,
                 asScheduleContent(pendingAction.getRemindAt()),
                 new StateAction.Trigger.Call(() -> {
-                    handlePendingReminder(pendingAction.getPendingId());
+                    handlePendingReminder(pendingAction.getPendingId(), pendingAction.getUserId());
                     return Unit.INSTANCE;
                 })
         );
@@ -221,14 +221,14 @@ public class ActionPlanner extends AbstractAgentModule.Running<PartnerRunningFlo
         );
     }
 
-    private void handlePendingReminder(String pendingId) {
+    private void handlePendingReminder(String pendingId, String userId) {
         boolean marked = actionCapability.markPendingReminded(pendingId);
         if (!marked) {
             return;
         }
         try {
             // TODO target 指定行为待补充; 主动回复链路待补充
-            cognationCapability.initiateTurn("系统提醒：存在待确认行动即将过期，请确认是否继续执行。pendingId=" + pendingId);
+            cognationCapability.initiateTurn("系统提醒：存在待确认行动即将过期，请确认是否继续执行。pendingId=" + pendingId, userId);
         } catch (Exception e) {
             log.warn("触发待确认行动提醒失败, pendingId: {}", pendingId, e);
         }
@@ -294,7 +294,7 @@ public class ActionPlanner extends AbstractAgentModule.Running<PartnerRunningFlo
                 result == null ? "" : result //将会在 ActionExecutor
         );
         try {
-            cognationCapability.initiateTurn(structuredSignal);
+            cognationCapability.initiateTurn(structuredSignal, action.getSource());
         } catch (Exception e) {
             log.warn("触发 immediate 行动完成自对话失败, actionUuid: {}", action.getUuid(), e);
         }