(self, raw_input: Any)
| 828 | return {"type": "text", "payload": str(payload)} |
| 829 | |
| 830 | def _normalize_task_input(self, raw_input: Any) -> List[Message]: |
| 831 | if isinstance(raw_input, list): |
| 832 | messages: List[Message] = [] |
| 833 | for item in raw_input: |
| 834 | if isinstance(item, Message): |
| 835 | messages.append(self._ensure_source(item, "TASK")) |
| 836 | elif isinstance(item, str): |
| 837 | messages.append(self._create_message(MessageRole.USER, item, "TASK")) |
| 838 | return messages or [self._create_message(MessageRole.USER, "", "TASK")] |
| 839 | if isinstance(raw_input, Message): |
| 840 | return [self._ensure_source(raw_input, "TASK")] |
| 841 | return [self._create_message(MessageRole.USER, str(raw_input), "TASK")] |
| 842 | |
| 843 | def _ensure_source(self, message: Message, default_source: str) -> Message: |
| 844 | cloned = message.clone() |
no test coverage detected