߲jddZddlmZddlZddlmZdZdZdZd dZ efd d  dd Z dd Z y)uRoute bulk request payloads around the OpenAI SDK's request transform (#93650). ``responses.create`` and ``chat.completions.create`` both re-walk the whole request body against their TypedDict/union param graph client-side, with the GIL held, before any byte leaves the process. #93650 documents that walk wedging for 12+ hours on a ~1.4 MB conversation — starving the TTFB/stale watchdogs whose job is to rescue this exact call; the hang is pre-network, so no socket kill helps. Hermes assembles these payloads from JSON round-trips, so they are already wire format and the walk has nothing to convert. The SDK merges ``extra_body`` into the JSON body *after* the transform (``_base_client._build_request``), so moving the bulk fields there skips the walk and yields the same request bytes. ) annotationsN)Any)inputtools)messagesrHERMES_CODEX_SDK_TRANSFORMc| t|ttttfryt|t r t d|jDSt|trt d|DSy)ziTrue when ``value`` is purely JSON wire types; pydantic models / generators must keep the typed SDK path.Tc3\K|]$\}}t|txr t|&ywN) isinstancestr_is_plain_json_data).0keyitems ?/home/ubuntu/.hermes/hermes-agent/agent/sdk_transform_bypass.py z&_is_plain_json_data.."s)e)#t:c3'E,?,EEes*,c32K|]}t|ywr )r)rrs rrz&_is_plain_json_data..$s?&t,?sF) r r intfloatbooldictallitemslist)values rrrs_ } 53UD*AB%eW\WbWbWdeee%???? F keep_slotscftjjtdj j dvr|S|Dcic];}t |j|ttfrt||r|||=}}|s|S|jDcic]\}}|s||vr |||vr|rgn|n|}}}|jd}t |tr t|ni} i| |jD cic] \}} || vs || c} }|d<|Scc}wcc}}wcc} }w)uMove wire-format bulk ``fields`` into ``extra_body``. Returns ``request_kwargs`` itself when nothing is safe to move, so callers use the result unconditionally. ``keep_slots`` leaves an empty-list placeholder in the typed kwargs for each moved field: it satisfies ``@required_args`` (``messages`` on chat.completions) and keeps the field's position in the JSON body, so the bytes — and therefore any byte-keyed prompt cache — are unchanged. >1onyestrue extra_body) osenvirongetESCAPE_HATCH_ENVstriplowerr rrrr) request_kwargsfieldsrfmovedrrbypassedr&mergedvs rbypass_sdk_request_transformr4(sE zz~~&+11399;?YY+1 la>--a04,?DWXfghXiDjq! ! lE l "0"6"6"8\CJ#UZJZcUlJbEM\H\l+J!+J!=T* 2F^^EKKM*]DAqQV\_1a4*]^H\ O l\ +^s AD""D' D-D-ctt|dddd}|$t|jjds|St |t dS)alChat-completions bypass, gated on the real OpenAI SDK. Only the SDK performs the transform and only the SDK merges ``extra_body`` afterwards. Hermes also drives chat-shaped facades that are NOT the SDK (the in-process MoA aggregator, test stand-ins); handing those an ``extra_body`` they never merge would silently send an empty conversation. chatN completionszopenai.Tr)getattrtype __module__ startswithr4CHAT_COMPLETIONS_BYPASS_FIELDS)r-clientr7s r!bypass_chat_sdk_request_transformr>EsP'&&$7MK${"3">">"I"I)"T '8Vcg hhr)rrreturnr)r-rr.ztuple[str, ...]rrr?r)r-rr=rr?r) __doc__ __future__rr'typingrRESPONSES_BYPASS_FIELDSr<r*rr4r>rrrEsn # -!606     : ir