You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2025/03/10 19:44:40 UTC
(airavata) 16/31: add back kernel launcher to agent
This is an automated email from the ASF dual-hosted git repository.
lahirujayathilake pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git
commit 8061e070b5bf455e48df2ac25ef10c90e62fcfe1
Author: yasith <ya...@icloud.com>
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 {