send start msg on run

Author: rainsonGain

aworld/core/agent/base.py

@@ -17,7 +17,7 @@
 from aworld.logs.util import logger
 from aworld.output.base import StepOutput
 from aworld.sandbox.base import Sandbox
-from aworld.utils.common import convert_to_snake, replace_env_variables
+from aworld.utils.common import convert_to_snake, replace_env_variables, sync_exec
 
 INPUT = TypeVar('INPUT')
 OUTPUT = TypeVar('OUTPUT')
@@ -145,6 +145,13 @@ def desc(self) -> str:
     def run(self, message: Message, **kwargs) -> Message:
         self._init_context(message.context)
         observation = message.payload
+        sync_exec(send_message, Message(
+            category=Constants.OUTPUT,
+            payload=StepOutput.build_start_output(name=f"{self.id()}", alias_name=self.name(), step_num=0),
+            sender=self.id(),
+            session_id=self.context.session_id,
+            headers={"context": self.context}
+        ))
         self.pre_run()
         result = self.policy(observation, message=message, **kwargs)
         final_result = self.post_run(result, observation)