+ WiMRt^RIHt^RIt^RIHtHtHtHtH t H t ^RI t ^RI t ^RI HtHt^RIHtHtHtHtHtHtHtHtHtRRltRR ltR R ltR R ltRRltRRltRRlt R#)zUtilities for the Research API.) annotationsN)AnyAsyncGeneratorDict GeneratorOptionalType) BaseModelValidationError) ResearchEventResearchDefinitionEventResearchOutputEventResearchPlanDefinitionEventResearchPlanOperationEventResearchPlanOutputEventResearchTaskDefinitionEventResearchTaskOperationEventResearchTaskOutputEventc V^8dQhRRRR/#)schemarreturnbool)formats"T/home/ubuntu/hermes-agent/venv/lib/python3.14/site-packages/exa_py/research/utils.py __annotate__r s  c d c\V\4;'d\V\4# \\ 3dR#i;i)zCheck if the given schema is a Pydantic model class. Args: schema: The schema to check. Returns: True if schema is a Pydantic model class, False otherwise. F) isinstancetype issubclassr TypeErrorAttributeError)rs&ris_pydantic_modelr$ s:&$'IIJvy,II ~ &s**??c V^8dQhRRRR/#)rmodelzType[BaseModel]rDict[str, Any]r)rs"rrr/s ( (? (~ (rc^RIHpV!V4#)zConvert a Pydantic model to JSON Schema. Args: model: The Pydantic model class. Returns: JSON Schema dictionary with all references inlined. )_convert_schema_input) exa_py.utilsr))r&r)s& rpydantic_to_json_schemar+/s3 ! ''rc V^8dQhRRRR/#)rlinestrrzOptional[tuple[str, str]]r)rs"rrr?s(((!:(rcV'dVP4'gR#RV9dR#VPR4wrpVP4VP43#)zParse a single SSE line. Args: line: The SSE line to parse. Returns: Tuple of (field, value) or None if not a valid SSE line. N:)strip partition)r-field_values& rparse_sse_liner6?sG tzz|| $nnS)OEe ;;=%++- ''rc V^8dQhRRRR/#)r event_linesz list[str]rzOptional[Dict[str, Any]]r)rs"rrrRs!!Y!3K!rc<RpRpVFGp\V4pV'gKVwrVVR8XdTpK'VR8XgK0\P!V4pKI V'd%V'd\ V\ 4'dWR&V#R# \PdTpKi;i)zParse SSE event lines into a raw event dictionary. Args: event_lines: List of lines that make up an SSE event. Returns: Parsed event data or None if invalid. Neventdata eventType)r6jsonloadsJSONDecodeErrorrdict)r8 event_name event_datar-parsedr3r5s& rparse_sse_event_rawrDRsJJ%   G J f_ #!ZZ. j j$ ' '&0{ # '' #"  #sBBBc V^8dQhRRRR/#)r raw_eventr'rzOptional[ResearchEvent]r)rs"rrrvs!!N!7N!rcVPR4pV'gR#R\R\R\R\R\ R\ R \R \/pVPV4pV'gR#VPV4# \dR#i;i) zParse a raw event dictionary into a typed ResearchEvent. Args: raw_event: Raw event dictionary with eventType field. Returns: Typed ResearchEvent or None if parsing fails. r<Nzresearch-definitionzresearch-outputzplan-definitionzplan-operationz plan-outputztask-definitionztask-operationz task-output) getr r rrrrrrmodel_validater )rF event_type event_models model_classs& rparse_research_eventrMvs{+J  6.64.64. L"":.K )))44 s*A;; B  B c V^8dQhRRRR/#)rresponsezrequests.Responserz$Generator[ResearchEvent, None, None]r)rs"rrrs!!!)!rc#".pVP4F}pV'g9V'd/\V4pV'd\V4pV'dVx.pKAKC\V\4'dVP R4MTpVP V4K V'd1\V4pV'd\V4pV'dVxR#R#R#R#5i)zStream SSE events from a requests Response. Args: response: The streaming response object. Yields: Parsed ResearchEvent objects. zutf-8N) iter_linesrDrMrbytesdecodeappend)rOr8r-rFr: decoded_lines& rstream_sse_eventsrVsK##%/ < 0;E#  4>dE3J3J4;;w/PTL   | ,&' 4 (3E  s%CA5C2Cc V^8dQhRRRR/#)rrOzhttpx.Responserz#AsyncGenerator[ResearchEvent, None]r)rs"rrrs   ( rcf".pVP4RjxL pV'g:V'd0\V4pV'd\V4pV'dV5x.pKIKKVPV4K^LYDZT'd2\T4pT'd\T4pT'dT5xR#R#R#R#5i)zStream SSE events from an httpx Response. Args: response: The async streaming response object. Yields: Parsed ResearchEvent objects. N) aiter_linesrDrMrT)rOr8r-rFr:s& rasync_stream_sse_eventsrZsK**, % %d/ < 0;E#     t $ %,' 4 (3E  s1B1A5A3A5B1AB13A55B1>3B1)!__doc__ __future__rr=typingrrrrrrhttpxrequestspydanticr r modelsr r r rrrrrrr$r+r6rDrMrVrZrrrrbsX%"  /     ( (&!H!H!H r