minor

Signed-off-by: Lei Wang <jiede.wl@alibaba-inc.com>
GraphScope · Jun 17, 2024 · b3aa41f · b3aa41f
1 parent e59dcd4
commit b3aa41f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/scripts/controller.py b/scripts/controller.py
@@ -83,10 +83,10 @@ def run_gie_task():
         pod_service_port = os.getenv("GIE_EXECUTOR_POD_SERVICE_PORT", 80)
         cmd = f"curl -X POST http://{pod_base_name}-{idx}.{pod_service_name}:{pod_service_port}/start-gie-executor -d 'read_epoch={read_epoch}&etcd_prefix={etcd_prefix}&etcd_endpoint={etcd_server}'"
         return cmd, 200
-        #launch_gie_executor_result = subprocess.run(
-        #    cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True, shell=True
-        #)
-        #print(launch_gie_executor_result.stdout + "\n" + launch_gie_executor_result.stderr)
+        launch_gie_executor_result = subprocess.run(
+            cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True, shell=True
+        )
+        print(launch_gie_executor_result.stdout + "\n" + launch_gie_executor_result.stderr)
     #TODO(wanglei): check if all gie executors are launched successfully
     time.sleep(5)
     gremlin_client = Client(f"ws://{etcd_server}/gremlin", "g")

diff --git a/scripts/update_gie_executor_config.py b/scripts/update_gie_executor_config.py
@@ -50,7 +50,7 @@ def start_gie_executor():
     etcd_prefix = request.form.get("etcd_prefix", "gart_meta_")
     if etcd_prefix is None:
         return "etcd_prefix is required", 400
-    cmd = f"/home/graphscope/GART/scripts/launch_gie_executor.sh start {etcd_endpoint} {etcd_prefix} {read_epoch}"
+    cmd = f"/home/graphscope/GART/scripts/launch_gie_executor.sh {etcd_endpoint} {etcd_prefix} {read_epoch}"
     subprocess.run(
         [
             "/bin/bash",