fix: fix bug when bbdev used in buckyball

Author: shirohasuki

api/motia.config.ts

@@ -0,0 +1,10 @@
+import { defineConfig } from '@motiadev/core'
+import endpointPlugin from '@motiadev/plugin-endpoint/plugin'
+import logsPlugin from '@motiadev/plugin-logs/plugin'
+import observabilityPlugin from '@motiadev/plugin-observability/plugin'
+import statesPlugin from '@motiadev/plugin-states/plugin'
+import bullmqPlugin from '@motiadev/plugin-bullmq/plugin'
+
+export default defineConfig({
+  plugins: [observabilityPlugin, statesPlugin, endpointPlugin, logsPlugin, bullmqPlugin],
+})

api/package.json

@@ -10,9 +10,20 @@
     "start": "motia start",
     "clean": "rm -rf dist node_modules python_modules .motia .mermaid"
   },
-  "keywords": ["motia"],
+  "keywords": [
+    "motia"
+  ],
   "dependencies": {
-    "motia": "0.8.2-beta.139",
-    "zod": "^3.24.4"
+    "motia": "0.17.14-beta.196",
+    "zod": "^3.24.4",
+    "@motiadev/core": "0.17.14-beta.196",
+    "@motiadev/plugin-logs": "0.17.14-beta.196",
+    "@motiadev/plugin-states": "0.17.14-beta.196",
+    "@motiadev/plugin-endpoint": "0.17.14-beta.196",
+    "@motiadev/plugin-observability": "0.17.14-beta.196",
+    "@motiadev/plugin-bullmq": "0.17.14-beta.196",
+    "@motiadev/plugin-streams": "0.17.14-beta.196",
+    "@motiadev/plugin-cron": "0.17.14-beta.196",
+    "@motiadev/plugin-ws": "0.17.14-beta.196"
   }
 }

api/pnpm-lock.yaml

@@ -29,7 +29,7 @@ async def handler(data, context):
 
     sardine_dir = f"{bbdir}/bb-tests/sardine"
 
-    command = f"python run_tests.py --allure -m \"({data.get('workload', '')})\""
+    command = f"python3 run_tests.py --allure -m \"({data.get('workload', '')})\""
     context.logger.info(
         "Executing sardine command", {"command": command, "cwd": sardine_dir}
     )

api/steps/sardine/01_run_event_step.py

@@ -67,10 +67,11 @@ async def handler(data, context):
         cflags += " -DCOSIM"
     ldflags = (
         f"-lreadline -ldramsim -lfesvr -lstdc++ "
+        f"-L{bebop_isa_sim}/install/lib "
+        f"-L{bbdir}/result/lib "
         f"-L{arch_dir}/thirdparty/chipyard/tools/DRAMSim2 "
         f"-L{arch_dir}/thirdparty/chipyard/toolchains/riscv-tools/riscv-isa-sim/build "
-        f"-L{arch_dir}/thirdparty/chipyard/toolchains/riscv-tools/riscv-isa-sim/build/lib "
-        f"-L{bebop_isa_sim}/install/lib"
+        f"-L{arch_dir}/thirdparty/chipyard/toolchains/riscv-tools/riscv-isa-sim/build/lib"
     )
 
     obj_dir = f"{build_dir}/obj_dir"

api/steps/verilator/03_build_event_step.py

@@ -67,10 +67,14 @@ async def handler(data, context):
     # ==================================================================================
     # Execute simulation script with streaming output
     # ==================================================================================
-    # batch_param = "True" if batch else "False"
-    # sim_cmd = f"./scripts/sim.sh {bin_path} {binary_path} {log_dir}/stdout.log \
-    # {log_dir}/disasm.log {batch_param} {vcd_path} {log_path}"
+    bebop_isa_sim = f"{bbdir}/bebop/host/spike/riscv-isa-sim"
+    ld_lib_path = (
+        f"{bebop_isa_sim}/install/lib:"
+        f"{bbdir}/result/lib:"
+        f"{arch_dir}/thirdparty/chipyard/tools/DRAMSim2"
+    )
     sim_cmd = (
+        f"export LD_LIBRARY_PATH=\"{ld_lib_path}:$LD_LIBRARY_PATH\"; "
         f"{bin_path} +permissive +loadmem={binary_path} +loadmem_addr=800000000 "
         f"{'+batch ' if batch else ''} "
         f"+fst={fst_path} +log={log_path} +permissive-off "

api/steps/verilator/04_cosim_event_step.py

@@ -67,10 +67,14 @@ async def handler(data, context):
     # ==================================================================================
     # Execute simulation script with streaming output
     # ==================================================================================
-    # batch_param = "True" if batch else "False"
-    # sim_cmd = f"./scripts/sim.sh {bin_path} {binary_path} {log_dir}/stdout.log \
-    # {log_dir}/disasm.log {batch_param} {vcd_path} {log_path}"
+    bebop_isa_sim = f"{bbdir}/bebop/host/spike/riscv-isa-sim"
+    ld_lib_path = (
+        f"{bebop_isa_sim}/install/lib:"
+        f"{bbdir}/result/lib:"
+        f"{arch_dir}/thirdparty/chipyard/tools/DRAMSim2"
+    )
     sim_cmd = (
+        f"export LD_LIBRARY_PATH=\"{ld_lib_path}:$LD_LIBRARY_PATH\"; "
         f"{bin_path} +permissive +loadmem={binary_path} +loadmem_addr=800000000 "
         f"{'+batch ' if batch else ''} "
         f"+fst={fst_path} +log={log_path} +permissive-off "

api/steps/verilator/04_sim_event_step.py

@@ -3,4 +3,5 @@
 
 def get_buckyball_path():
     current_dir = os.path.dirname(__file__)
-    return os.path.dirname(os.path.dirname(current_dir))
+    # bbdev/api/utils -> bbdev/api -> bbdev -> buckyball
+    return os.path.dirname(os.path.dirname(os.path.dirname(current_dir)))

api/utils/path.py

@@ -449,11 +449,41 @@ if __name__ == "__main__":
                 available_port = find_available_port(start_port=5100, end_port=5500)
             print(f"Starting server on port {available_port}...")
             proc = subprocess.Popen(
-                ["pnpm", "dev", "--port", str(available_port)], cwd=workflow_dir
+                ["pnpm", "dev", "--port", str(available_port)],
+                cwd=workflow_dir,
+                start_new_session=True,
+                stdout=subprocess.PIPE,
+                stderr=subprocess.PIPE,
             )
 
+            # Forward stdout/stderr in background threads; stopped before
+            # shutdown to suppress BullMQ teardown errors and pnpm's
+            # ELIFECYCLE message (Motia framework limitation).
+            import threading
+
+            output_active = threading.Event()
+            output_active.set()
+
+            def forward_stream(stream, dest):
+                for line in iter(stream.readline, b""):
+                    if not output_active.is_set():
+                        break
+                    dest.write(line)
+                    dest.flush()
+
+            threading.Thread(
+                target=forward_stream,
+                args=(proc.stdout, sys.stdout.buffer),
+                daemon=True,
+            ).start()
+            threading.Thread(
+                target=forward_stream,
+                args=(proc.stderr, sys.stderr.buffer),
+                daemon=True,
+            ).start()
+
             # Wait for service to start
-            max_retries = 30
+            max_retries = 600
             for i in range(max_retries):
                 try:
                     # Disable proxy, connect directly to localhost
@@ -506,10 +536,22 @@ if __name__ == "__main__":
             )
 
             # 3. Shutdown service ================================
-            # Give observability plugin time to finish async operations (e.g., Redis writes)
+            output_active.clear()
+            import signal
+
             time.sleep(1)
-            proc.terminate()
-            proc.wait()
+            try:
+                os.killpg(os.getpgid(proc.pid), signal.SIGTERM)
+            except ProcessLookupError:
+                pass
+            try:
+                proc.wait(timeout=10)
+            except subprocess.TimeoutExpired:
+                try:
+                    os.killpg(os.getpgid(proc.pid), signal.SIGKILL)
+                except ProcessLookupError:
+                    pass
+                proc.wait()
             print(
                 f"\nTask completed. Command running on http://localhost:{available_port} is finished"
             )

bbdev

@@ -29,16 +29,13 @@
 
           shellHook = ''
             export PATH="$PWD:$PATH"
+            source "$PWD/init.sh"
 
             echo "bbdev dev environment ready"
             echo "  Node.js: $(node --version)"
             echo "  Python:  $(python3 --version)"
             echo "  pnpm:    $(pnpm --version)"
             echo "  bbdev:   $(which bbdev)"
-            echo ""
-            echo "Quick start:"
-            echo "  pnpm install     # install node deps + motia install"
-            echo "  pnpm dev         # start motia dev server"
           '';
         };
       }