fix: fixed a bug in workflow agent steps (fixes #40)

Author: evilsocket

nerve/runtime/__init__.py

@@ -33,7 +33,7 @@ async def build(
         # import tools from builtin namespaces
         ns_tools = compiler.get_tools_from_namespaces(configuration.using, configuration.jail)
         if ns_tools:
-            logger.info(f"🧰 importing {len(ns_tools)} tools from: {configuration.using}")
+            logger.debug(f"🧰 importing {len(ns_tools)} tools from: {configuration.using}")
             runtime.tools.extend(ns_tools)
 
         # import custom tools from yaml definition
@@ -42,7 +42,7 @@ async def build(
             [tool for tool in configuration.tools if isinstance(tool, Tool) and not tool.path],
         )
         if yml_tools:
-            logger.info(f"🧰 importing {len(yml_tools)} tools from: {working_dir}")
+            logger.debug(f"🧰 importing {len(yml_tools)} tools from: {working_dir}")
             runtime.tools.extend(yml_tools)
 
         # import custom tools from files
@@ -51,13 +51,13 @@ async def build(
             [tool.path for tool in configuration.tools if isinstance(tool, Tool) and tool.path],
         )
         if py_tools:
-            logger.info(f"🧰 importing {len(py_tools)} tools from: {working_dir}")
+            logger.debug(f"🧰 importing {len(py_tools)} tools from: {working_dir}")
             runtime.tools.extend(py_tools)
 
         # import custom tools from functions (when used as sdk)
         funcs = [compiler.wrap_tool_function(tool) for tool in configuration.tools if callable(tool)]
         if funcs:
-            logger.info(f"🧰 importing {len(funcs)} custom tools")
+            logger.debug(f"🧰 importing {len(funcs)} custom tools")
             runtime.tools.extend(funcs)
 
         # import MCP servers

nerve/runtime/flow.py

@@ -135,6 +135,7 @@ async def step(self) -> None:
         if state.is_active_task_done():
             logger.debug(f"task {self.curr_actor.runtime.name} complete")  # type: ignore
             self.curr_actor_idx += 1
+            self.curr_actor = None
             state.reset()
 
         self.curr_step += 1
@@ -167,6 +168,7 @@ async def _reset(self) -> None:
         state.reset()
         await self.shell.reset()
         self.curr_actor_idx = 0
+        self.curr_actor = None
 
     async def run(self, task_override: str | None = None) -> None:
         state.on_event(