j%dZddlmZddlZddlZddlZddlZddlmZm Z m Z m Z eje Zejdej ZdZGddeZdd Zd Zdd Zdd Zdd Zddd ddZy)uQwen VLM 판정 클라이언트 — DashScope OpenAI 호환 직접 호출 (2026-08-10). `backend/qwen_vlm_pilot.py` 에서 검증된 부품의 프로덕션 이관이다. Router (`call_structured`)를 타지 않는 이유: 이 저장소의 구조화 호출은 `response_format={"type":"json_schema","strict":true}` 를 보내는데 DashScope 는 그것을 지원하지 않는다 — `json_object` 만 되고, 메시지 어딘가에 "json" 이라는 낱말이 없으면 400, thinking 모드는 구조화 출력과 충돌한다. 그래서 스키마 전문을 시스템에 동봉하고 여기서 `jsonschema` 로 검증한 뒤, 실패하면 오류를 되먹여 한 번 다시 묻는다. ★litellm 우회 직접 호출이므로 **모든 API 왕복을 `record_provider_call` 로 남긴다** (llm_call_log+Opik — 2026-08-07 전수 기록 지시). 우회 호출 AST 스캐너(`test_all_provider_calls_are_traced`)가 이 배선을 검사한다. ) annotationsN)AnyDictListOptionalz```(?:json)?\s*(.*?)\s*```u OUTPUT FORMAT — return one single json object and nothing else. No prose before or after it, no markdown code fence. It must match this json schema exactly, including every required key: {schema}c eZdZy)QwenNotConfiguredN)__name__ __module__ __qualname__U/Users/manta/Documents/Projects/TheRoad-I1/backend/app/modules/llm/qwen_vlm_client.pyr r &srr c\ddlm}t|jxsdj SNrsettings)app.core.configrbooldashscope_api_keystriprs rqwen_configuredr*s$( ++1r88: ;;rcddlm}|jxsdj}|s t dddlm}|||jxsdjdS)NrrruJDASHSCOPE_API_KEY 가 비어 있다 — backend/.env 에 키를 넣어라.)OpenAIgr@)api_keybase_urltimeout)rrrrr openairdashscope_base_url)rkeyrs r_clientr"0s`(  % % + 2 2 4C  X   --3::< rcJddlm}|jxsdjSr)rrqwen_vlm_modelrrs r qwen_modelr%As(  # # )r 0 0 22rch|xsdj} tj|S#tj$rYnwxYwtj |}|r> tj|j dS#tj$rYnwxYw|jd}|dk\rtd\}}}t||d|D]\\}}|r|rd}n|dk(rd }n|d k(rd}|d k(rd }%|dk(r|dz }0|d k(s6|dz}|dk(sAtj|||dzcStd |dd )ud추론 텍스트가 앞뒤에 섞여 와도 본체 json 을 꺼낸다. thinking 모드가 content 에 추론을 흘리는 사례가 보고돼 있어 관용 파싱이 필요하다. ①코드펜스 안 ②첫 `{` 부터 균형 잡힌 마지막 `}` 까지 순으로 시도. (pilot 검증 부품 — 256샷 실측에서 전 샷 파싱 성공) r{r)rFFNF\T"}ujson 을 찾지 못했다: ) rjsonloadsJSONDecodeError_FENCEsearchgroupfind enumerate ValueError)textmstartdepthin_strescichs r extract_jsonr>GsP JB   D zz$       dA ::aggaj) )##    IIcNE z,vstEF|U3EArC4ZC3Y"FSys s A:::d5Q&788!4" 24:.A BBs!+AA#BBBc2djd|DS)ud기록용 프롬프트 — 텍스트 파트만 잇는다 (base64 이미지는 DB 에 안 싣는다). c3K|]7}|jddk(st|jdxsd9yw)typer6rN)getstr).0ps r z"_prompt_text_of..rs5*/Q155=F3JAEE&M R %s?#?)join)partss r_prompt_text_ofrJps 99*/ rr') max_retry opik_metadatac ddlm}m}ddlm}mm} ttc} |tjtj|ddz} d| d d |d g} t||xsijD]\} }| | vs|| <| t|d d d  d)fd}d}t!|dzD]}d }ddid fD]J}t#j"} | j$j&j(d*| ddid|rd|ini}n| t1dt-t#j"z dz} |j2dj4j6xsd}t9|t:s!t=dt?|j@ tC|}||||d|| |cSt1d(#t*$r`}t-t#j"|z dz}| dt/|vr|d |t/|d d|d |dYd }~kd }~wwxYw#t*$r}|d |d|d dd }~wwxYw#tD|tjFf$rP}t?|j@d!|d d}|d |d"|||k\r| d#|d d$d d d%|d&d gz } Yd }~d }~wt*$r}|d |d'|d dd }~wwxYw)+uQwen 에 멀티모달 판정을 묻고 스키마 검증을 통과한 payload 를 돌려준다. parts 는 `call_structured` 멀티모달 parts 와 같은 형식(`png_part`/ `ref_parts` 산출 — OpenAI chat `image_url` data URI) — 실측 갤러리에서 같은 parts 를 Gemini·Qwen 두 경로에 태워 호환 확인됨. 스키마 검증 실패 = 오류를 되먹여 교정 재질의 `max_retry` 회. 네트워크 재시도는 여기 없다 — 필요가 실측되면 그때 더한다(선제 확장 금지). r)ValidationErrorvalidate)ambient_call_metarecord_provider_callresolve_step_nameF) ensure_asciiindent)schemasystem)rolecontentuserN)outputerrorr\c *||d || y)N dashscope) stepmodelpromptstatus duration_msmetaprovider operation output_textr\r ) rbdur_msr[r\ log_promptrdr`rQr_step_tags r_recordz$ask_qwen_structured.._records#U:fTKF% Arrr'enable_thinkingrB json_object)r`messagesresponse_format extra_bodyi400i)r\u3enable_thinking 미지원(400) — 빼고 재시도u:qwen 호출이 응답 없이 폴백 루프를 벗어났다u'message.content 가 str 이 아니다: zunexpected response shape: isuccess)r[z: zschema violation: assistantiz,That reply did not satisfy the json schema: z' Return the corrected json object only.z"unexpected post-response failure: unreachable) rbrDrhintr[ Optional[str]r\rvreturnNoner )$ jsonschemarNrOapp.modules.llm.image_tracerrPrQrRr"r% JSON_CLAUSEformatr-dumpsdictitemsrJrangetimechat completionscreate Exceptionrurepr RuntimeErrorchoicesmessagerY isinstancerD TypeErrorrBr r>r5r/)rjrWrIrVrKrLrN _js_validaterPrRclient sys_promptrnkvrklast_errattemptrespextrat0excdurrYpayloadrirdr`rQr_s` @@@@@rask_qwen_structuredrws$EDDIz|MFE+,,zz&uQ?-AAJj1E*&H !# $D$"++-1 =Qd]DG. Xt ,D 'JEI'+A$A04AAHQ')%0$7EB U5v{{..55%%+]$;16 e,2  8" <[\ \499;#t+, ll1o--55;Ggs+=G}--.011, "7+G & ) Is7 3NW(H } %%m U499;+t34=Ec$:GSS $3@SUU  U*  GS7w?E G  OT-A-AB s),,-Ru5ds;H GS*sgFtL N  sW:2G) AI: I8) I2AI  I I5I00I58LAK L)K;;L)rwr)rwrD)r6rDrwDict[str, Any])rIList[Dict[str, Any]]rwrD)rjrDrWrDrIrrVrrKrurLzOptional[Dict[str, Any]]rwr)__doc__ __future__rr-loggingrertypingrrrr getLoggerr loggercompileSr0r{rr rr"r%r>rJrr rrrs #  ,,   8 $ 1244 8   < "3 &CR.2q&q& q& q&  q&  q&,q&q&r