From 997c4e72624b6f146f0281eb84320c82d26cf39a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=85=AC=E6=98=8E?= <83812544+Ed1s0nZ@users.noreply.github.com> Date: Sat, 27 Jun 2026 01:44:08 +0800 Subject: [PATCH] Add files via upload --- internal/multiagent/eino_execute_streaming_wrap.go | 2 +- internal/multiagent/eino_execute_streaming_wrap_test.go | 6 ------ internal/multiagent/runner.go | 2 +- 3 files changed, 2 insertions(+), 8 deletions(-) diff --git a/internal/multiagent/eino_execute_streaming_wrap.go b/internal/multiagent/eino_execute_streaming_wrap.go index 51232d16..96afbf3a 100644 --- a/internal/multiagent/eino_execute_streaming_wrap.go +++ b/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) diff --git a/internal/multiagent/eino_execute_streaming_wrap_test.go b/internal/multiagent/eino_execute_streaming_wrap_test.go index 068eb9bb..43d0e819 100644 --- a/internal/multiagent/eino_execute_streaming_wrap_test.go +++ b/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