This is an automated email from the ASF dual-hosted git repository. lahirujayathilake pushed a commit to branch cybershuttle-dev in repository https://gitbox.apache.org/repos/asf/airavata.git
commit 84e5ebf7edd52598b944a26710ed7a3d0f218656 Author: yasith <[email protected]> AuthorDate: Wed Feb 26 02:19:46 2025 -0600 add back kernel launcher to agent --- modules/agent-framework/airavata-agent/agent.go | 102 ++++++++++++------------ 1 file changed, 51 insertions(+), 51 deletions(-) diff --git a/modules/agent-framework/airavata-agent/agent.go b/modules/agent-framework/airavata-agent/agent.go index 7ae28fcc37..4c241aa2cb 100644 --- a/modules/agent-framework/airavata-agent/agent.go +++ b/modules/agent-framework/airavata-agent/agent.go @@ -49,57 +49,57 @@ func main() { log.Printf("Connected to the server...") } - // go func() { - // log.Printf("Starting jupyter kernel") - // cmd := exec.Command("python", "/opt/jupyter/kernel.py") - // //cmd := exec.Command("jupyter/venv/bin/python", "jupyter/kernel.py") - // stdout, err := cmd.StdoutPipe() - - // if err != nil { - // fmt.Println("[agent.go] Error creating StdoutPipe:", err) - // return - // } - - // // Get stderr pipe - // stderr, err := cmd.StderrPipe() - // if err != nil { - // fmt.Println("[agent.go] Error creating StderrPipe:", err) - // return - // } - - // log.Printf("[agent.go] Starting command for execution") - // // Start the command - // if err := cmd.Start(); err != nil { - // fmt.Println("[agent.go] Error starting command:", err) - // return - // } - - // // Create channels to read from stdout and stderr - // stdoutScanner := bufio.NewScanner(stdout) - // stderrScanner := bufio.NewScanner(stderr) - - // // Stream stdout - // go func() { - // for stdoutScanner.Scan() { - // fmt.Printf("[agent.go] stdout: %s\n", stdoutScanner.Text()) - // } - // }() - - // // Stream stderr - // go func() { - // for stderrScanner.Scan() { - // fmt.Printf("[agent.go] stderr: %s\n", stderrScanner.Text()) - // } - // }() - - // // Wait for the command to finish - // if err := cmd.Wait(); err != nil { - // fmt.Println("[agent.go] Error waiting for command:", err) - // return - // } - - // fmt.Println("[agent.go] Command finished") - // }() + go func() { + log.Printf("Starting jupyter kernel") + cmd := exec.Command("python", "/opt/jupyter/kernel.py") + //cmd := exec.Command("jupyter/venv/bin/python", "jupyter/kernel.py") + stdout, err := cmd.StdoutPipe() + + if err != nil { + fmt.Println("[agent.go] Error creating StdoutPipe:", err) + return + } + + // Get stderr pipe + stderr, err := cmd.StderrPipe() + if err != nil { + fmt.Println("[agent.go] Error creating StderrPipe:", err) + return + } + + log.Printf("[agent.go] Starting command for execution") + // Start the command + if err := cmd.Start(); err != nil { + fmt.Println("[agent.go] Error starting command:", err) + return + } + + // Create channels to read from stdout and stderr + stdoutScanner := bufio.NewScanner(stdout) + stderrScanner := bufio.NewScanner(stderr) + + // Stream stdout + go func() { + for stdoutScanner.Scan() { + fmt.Printf("[agent.go] stdout: %s\n", stdoutScanner.Text()) + } + }() + + // Stream stderr + go func() { + for stderrScanner.Scan() { + fmt.Printf("[agent.go] stderr: %s\n", stderrScanner.Text()) + } + }() + + // Wait for the command to finish + if err := cmd.Wait(); err != nil { + fmt.Println("[agent.go] Error waiting for command:", err) + return + } + + fmt.Println("[agent.go] Command finished") + }() go func() { for {
