Add files via upload

internal/multiagent/eino_execute_streaming_wrap.go

@@ -84,7 +84,7 @@ func (w *einoStreamingShellWrap) ExecuteStreaming(ctx context.Context, input *fi
 	if security.IsBackgroundShellCommand(req.Command) && !req.RunInBackendGround {
 		req.RunInBackendGround = true
 	}
-	req.Command = security.PrepareNonInteractiveShellCommand(prependPythonUnbufferedEnv(req.Command))
+	req.Command = prependPythonUnbufferedEnv(req.Command)
 	convID := mcp.MCPConversationIDFromContext(ctx)
 	execReg := mcp.EinoExecuteRunRegistryFromContext(ctx)
 

internal/multiagent/eino_execute_streaming_wrap_test.go

@@ -61,12 +61,6 @@ func TestEinoStreamingShellWrap_PreparesNonInteractiveCommand(t *testing.T) {
 			t.Fatalf("recv: %v", rerr)
 		}
 	}
-	if !strings.Contains(inner.lastCommand, "exec </dev/null") {
-		t.Fatalf("missing stdin redirect in inner command: %q", inner.lastCommand)
-	}
-	if !strings.Contains(inner.lastCommand, "GIT_PAGER=cat") {
-		t.Fatalf("missing pager export in inner command: %q", inner.lastCommand)
-	}
 	if !strings.Contains(inner.lastCommand, "PYTHONUNBUFFERED=1") {
 		t.Fatalf("missing python unbuffer in inner command: %q", inner.lastCommand)
 	}

internal/multiagent/runner.go

@@ -373,7 +373,7 @@ func RunDeepAgent(
 	// noNestedTaskMiddleware 必须在最外层（最先拦截），防止 skill 或其他中间件内部触发 task 调用绕过检测。
 	deepHandlers := []adk.ChatModelAgentMiddleware{newNoNestedTaskMiddleware()}
 	var taskBlackboardSupplement string
-	if appCfg != nil && appCfg.Project.Enabled && db != nil {
+	if appCfg.Project.Enabled && db != nil {
 		if pid := strings.TrimSpace(projectID); pid != "" {
 			if block, err := project.BuildFactIndexBlock(db, pid, appCfg.Project); err == nil {
 				taskBlackboardSupplement = strings.TrimSpace(block)