Method update

apps/miroflow-agent/src/core/stream_handler.py:36–52

Send a streaming update in SSE protocol format. Args: event_type: The type of event (e.g., 'start_of_workflow', 'tool_call') data: The event payload data

(self, event_type: str, data: dict)

        self.stream_queue = stream_queue

    async def update(self, event_type: str, data: dict):
        """
        Send a streaming update in SSE protocol format.

        Args:
            event_type: The type of event (e.g., 'start_of_workflow', 'tool_call')
            data: The event payload data
        """
        if self.stream_queue:
            try:
                stream_message = {
                    "event": event_type,
                    "data": data,
                }
                await self.stream_queue.put(stream_message)
            except Exception as e:
                logger.warning(f"Failed to send stream update: {e}")

    async def start_workflow(self, user_input: str) -> str:
        """