Function create_reading_reports

deployments/desktop/shared/agents.py:2457–2492

(
    *,
    user_id: str,
    push_id: str,
    paper_numbers: Iterable[Any],
    write_feishu: Optional[bool] = None,
    response_language: str = "zh",
)

                doc_url=doc.get("url") or metadata.get("doc_url"),
                doc_token=doc.get("doc_token") or metadata.get("doc_token"),
            )
        except Exception as exc:
            doc["wiki_ingest_error"] = str(exc)
            continue
        if result:
            doc["wiki_ingest"] = result
            backfilled += 1
    return backfilled


def create_reading_reports(
    *,
    user_id: str,
    push_id: str,
    paper_numbers: Iterable[Any],
    write_feishu: Optional[bool] = None,
    response_language: str = "zh",
) -> Dict[str, Any]:
    push = db_ops.get_push_papers(push_id)
    if not push or not push.get("papers"):
        raise ValueError(f"Push not found: {push_id}")
    papers = list(push["papers"])
    selected = _unique_ints(paper_numbers, maximum=len(papers))
    should_write_feishu = _env_bool("PAPERFLOW_WRITE_FEISHU", default=False) if write_feishu is None else bool(write_feishu)
    language = _normalize_response_language(response_language)
    if not selected:
        return _reports_payload([], write_feishu_requested=should_write_feishu)

    with _reading_agent_output_env_patch(), _local_only_feishu_doc_patch(not should_write_feishu):
        docs = reading_agent.create_reading_report(
            user_id=user_id,
            paper_ids=selected,
            papers=papers,
            send_to_feishu=should_write_feishu,
            request_metadata={
                "selection_push_id": push_id,
                "report_source_type": "desktop_gui",
                "report_style": _configured_report_style(),
                "response_language": language,