fix: remove used wait_ function

Author: shirohasuki

api/pyproject.toml

@@ -7,6 +7,7 @@ dependencies = [
   "motia[otel]==1.0.0rc17",
   "iii-sdk==0.2.0",
   "pydantic>=2.0",
+  "PyYAML>=6.0",
 ]
 
 [project.optional-dependencies]

api/steps/pegasus/01_verilog_api.step.py

@@ -1,7 +1,6 @@
 from motia import ApiRequest, ApiResponse, FlowContext, api
 
 from utils.path import get_buckyball_path
-from utils.event_common import wait_for_result
 
 config = {
     "name": "Pegasus Verilog",
@@ -16,14 +15,11 @@ async def handler(req: ApiRequest, ctx: FlowContext) -> ApiResponse:
     bbdir = get_buckyball_path()
     body = req.body or {}
 
-    # Default config for Pegasus; allow override
     config_name = body.get("config", "sims.pegasus.PegasusConfig")
 
     data = {
         "config": config_name,
         "output_dir": body.get("output_dir", f"{bbdir}/arch/build/pegasus/"),
     }
-
     await ctx.enqueue({"topic": "pegasus.verilog", "data": {**data, "_trace_id": ctx.trace_id}})
-    result = await wait_for_result(ctx)
-    return result
+    return ApiResponse(status=202, body={"trace_id": ctx.trace_id})

api/steps/pegasus/02_buildbitstream_api.step.py

@@ -1,7 +1,5 @@
 from motia import ApiRequest, ApiResponse, FlowContext, api
 
-from utils.event_common import wait_for_result
-
 config = {
     "name": "Pegasus Buildbitstream",
     "description": "build pegasus bitstream",
@@ -14,5 +12,4 @@
 async def handler(req: ApiRequest, ctx: FlowContext) -> ApiResponse:
     body = req.body or {}
     await ctx.enqueue({"topic": "pegasus.buildbitstream", "data": {**body, "_trace_id": ctx.trace_id}})
-    result = await wait_for_result(ctx)
-    return result
+    return ApiResponse(status=202, body={"trace_id": ctx.trace_id})

api/steps/yosys/01_synth_api.step.py

@@ -1,7 +1,6 @@
 from motia import ApiRequest, ApiResponse, FlowContext, api
 
 from utils.path import get_buckyball_path
-from utils.event_common import wait_for_result
 
 config = {
     "name": "Yosys Synth",
@@ -22,9 +21,4 @@ async def handler(req: ApiRequest, ctx: FlowContext) -> ApiResponse:
         "config": body.get("config"),
     }
     await ctx.enqueue({"topic": "yosys.synth", "data": {**data, "_trace_id": ctx.trace_id}})
-
-    # ==================================================================================
-    #  Wait for synthesis result
-    # ==================================================================================
-    result = await wait_for_result(ctx)
-    return result
+    return ApiResponse(status=202, body={"trace_id": ctx.trace_id})

bbdev

@@ -255,16 +255,40 @@ def wait_for_http(url: str, check_fn, timeout: int, error_msg: str):
     return False
 
 
+_ENGINE_INFRA_MODULES = (
+    "iii::modules::worker",
+    "iii::modules::config",
+    "iii::modules::rest_api",
+    "iii::modules::api",
+    "iii::modules::queue",
+    "iii::modules::state",
+    "iii::modules::pubsub",
+    "iii::modules::shell",
+    "iii::modules::telemetry",
+    "iii::builtins",
+    "iii::trigger",
+    "iii::function",
+    "function_name",
+    "service_name",
+    "iii::services",
+    "iii::workers",
+    "motia.runtime",
+    "motia.tracing",
+    "motia.cli",
+)
+
+
 def forward_iii_output(pipe, active_event: threading.Event, quiet: bool = False):
-    """Forward task output to stdout. In quiet mode, suppress engine INFO/WARN logs."""
+    """Forward task output to stdout. In quiet mode, suppress engine infrastructure logs."""
     for line in iter(pipe.readline, ""):
         if not active_event.is_set():
             continue
         if quiet:
-            # Pass through: ANSI-colored step output and ERROR lines; drop engine INFO/WARN
-            if line.startswith("\033[") or "[ERROR]" in line:
-                sys.stdout.write(line)
-                sys.stdout.flush()
+            # Suppress engine infrastructure INFO/WARN; pass everything else
+            if any(mod in line for mod in _ENGINE_INFRA_MODULES):
+                continue
+            sys.stdout.write(line)
+            sys.stdout.flush()
         else:
             sys.stdout.write(line)
             sys.stdout.flush()