MagenticOne - expose Ledger messages

[michalmar]

What feature would you like to be added?

we are trying to capture ledger and display ledger messages/status in MagenticOne - but those updates/messages are not visible in standard "stream" of messages when you start the task - has anyone some guidance/advice on how to actually do that, please?

we are starting the exexution like:

team = MagenticOneGroupChat(
            participants=self.agents,
            model_client=self.client,
            max_turns=self.max_rounds,
            max_stalls=self.max_stalls_before_replan,
            
        )
        stream = team.run_stream(task=task)

and then capturing the messages:

 async for log_entry in stream:
            display_log_message(log_entry=log_entry, logs_dir=logs_dir)

(the ledger messages from orchestrator was exposed in 0.2 version)

Why is this needed?

it helps explains the overal progress and help understanding the process in whole

[ekzhu]

We can have a text message emitted right here:

autogen/python/packages/autogen-agentchat/src/autogen_agentchat/teams/_group_chat/_magentic_one/_magentic_one_orchestrator.py

Lines 335 to 336 in 226b37d

	# Check for task completion

Just add

await self.publish_message(
    GroupChatMessage(TextMessage(content=json.dumps(progress_ledger), source=self._name)),
    topic_id=DefaultTopicId(type=self._output_topic_type),
)

This will be serialized JSON. However, we can add a new message type for structured messages to help the consumer understand what to expect in the message itself. This also allows for filtering at the consumer of the stream to decide whether to display the message to the console.

@afourney