Return the answer payload (if any) from a message.
(message: dict[str, Any])
| 18 | |
| 19 | |
| 20 | def _extract_answer_payload(message: dict[str, Any]) -> dict[str, Any] | None: |
| 21 | """Return the answer payload (if any) from a message.""" |
| 22 | if not isinstance(message, dict): |
| 23 | return None |
| 24 | |
| 25 | # handle Message schema (`content`) as well as legacy top-level fields |
| 26 | payload = message.get("content") |
| 27 | if isinstance(payload, dict) and "answer" in payload: |
| 28 | return payload |
| 29 | |
| 30 | if message.get("answer"): |
| 31 | payload = {key: message.get(key) for key in ("answer", "items", "@type") if key in message} |
| 32 | return payload or None |
| 33 | |
| 34 | return None |
| 35 | |
| 36 | |
| 37 | def _collect_results(messages: Iterable[dict[str, Any]]) -> tuple[list[dict[str, Any]], list[str]]: |
no test coverage detected