(self)
| 738 | return final_message.text_content() if final_message else "" |
| 739 | |
| 740 | def get_final_output_message(self) -> Message | None: |
| 741 | if self.graph.is_majority_voting: |
| 742 | if self.majority_result is None: |
| 743 | return None |
| 744 | if isinstance(self.majority_result, Message): |
| 745 | return self.majority_result.clone() |
| 746 | return self._create_message(MessageRole.ASSISTANT, str(self.majority_result), "MAJORITY_VOTE") |
| 747 | |
| 748 | final_node = self._get_final_node() |
| 749 | if not final_node: |
| 750 | return None |
| 751 | if final_node.output: |
| 752 | value = final_node.output[-1] |
| 753 | if isinstance(value, Message): |
| 754 | return value.clone() |
| 755 | return self._create_message(MessageRole.ASSISTANT, str(value), final_node.id) |
| 756 | return None |
| 757 | |
| 758 | def get_final_output_messages(self) -> List[Message]: |
| 759 | """Return all messages from the final node.""" |
no test coverage detected