[jOSSKJr SSKrSSKrSSKJrJrJrJrJ r SSK J r SSK J r SSKrSSKJrJrJrJrJr SS KJr SS KJrJrJrJrJrJrJrJr SS K J!r!J"r" SS K#J$r$J%r% SS K&J'r' SSK(J)r)J*r* SSK+J,r, SSK-J.r. SSK/J0r0 SSK1J2r2 /SQr3SSjr4"SS\\)5r5"SS\\*5r6"SS\\)5r7"SS\\*5r8g)) annotationsN)AnyMappingCallableOptionalcast)Path)Literal)DEFAULT_WAIT_TIMEOUTJobListV2ResourceMixinpoll_until_terminalapoll_until_terminal)deepcopy_with_paths)BodyOmitQueryHeadersNotGiven FileTypesomit not_given)is_given extract_files)JobV2ParseResponse)normalize_parse_job)SyncAPIResourceAsyncAPIResource)APIStatusError)make_request_options)convert_url_to_file_if_local)raise_if_sync_timeout) ParseResourceAsyncParseResourceParseJobsResourceAsyncParseJobsResourcecB[U5(aUb0n[U5(a]UbZ[U[5(a[[R "U55O%[[ [[[4U55nURSU5 Un[U5(a0Ub-[U[5(d[R"U5OUnUUUUUS.nUR5VVs0sHupx[U5(dMUcMXx_M snn$s snnf)Npassword)document document_urlmodeloptionsr+) r isinstancestrdictjsonloadsrrr setdefaultdumpsitems) r,r-r.r/r+optsraw_bodykeyvalues ]/home/mande/repo/quber/.venv/lib/python3.13/site-packages/landingai_ade/resources/v2/parse.py_build_parse_bodyr=sh2! G  !40:7C0H0H4 7+,dSWX_`ceh`hXikrSsNtD  H-W0-7-E-E$**W%7$ H*2)9 c)9:3Xe_JQVJCJ)9 cc cs2D DDc b\rSrSr\\\\\SSSS\S. SSjjrSrg)r&?N r,r-r.r/r+save_to extra_headers extra_query extra_bodytimeoutc Xp[X5up[[XX4U5S//5n [[ [ [ [4U 5S//S9nSS0U=(d 0EnURURS5U U[XxXS9[S9nU(aS S KJnJn U"X5nU"UUS U5 U$![an[U5 eSnAff=f) a@Parse a document synchronously against the V2 (ADE) `/v2/parse` endpoint. Returns a `V2ParseResponse` on both a full success (HTTP 200) and a partial success (HTTP 206) -- in the 206 case `result.metadata.failed_pages` lists the pages that could not be parsed. Raises `V2SyncTimeoutError` when the server times out the synchronous request (HTTP 504); use the async jobs route for long-running documents in that case. Args: document: A file to be parsed. Either this parameter or `document_url` must be provided. document_url: The URL to the file to be parsed. Either this parameter or `document` must be provided. Local file paths are automatically converted to a `document` upload. model: The version of the model to use for parsing. options: Additional parsing options. Sent to the server as a JSON-encoded string form field. password: Password for encrypted document files. Sent to the server as `options.password` (an explicit `options["password"]` takes precedence) and, for older gateways, as a top-level form field. save_to: Optional output path. If a directory, auto-generates the filename (e.g. {input_file}_parse_output.json, or parse_output.json when no input filename is available). If a full path ending in .json, saves there directly. Parent directories are created automatically. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds r,paths Content-Typemultipart/form-data /v2/parserBrCrDrEbodyfilesr/cast_toNr_save_response_get_input_filenameparser$rr=rrrr1object_post_v2_urlr#rr"r%_clientrRrSselfr,r-r.r/r+rArBrCrDrEoriginal_documentoriginal_document_urlrNrOresultexcrRrSfilenames r<runParseResource.run@sh4<0!=h!U" heh O\N d73;#7> |nU()>X=CVTVX  ZZ [),"/U_( F  F*+<TH 7Hgv >   !# &  s .B22 C < CC r,Optional[FileTypes] | Omitr-Optional[str] | Omitr.rfr/%Optional[Mapping[str, object]] | Omitr+rfrAzstr | Path | NonerBHeaders | NonerC Query | NonerD Body | NonerE'float | httpx.Timeout | None | NotGivenreturnr__name__ __module__ __qualname____firstlineno__rrra__static_attributes__rcr<r&r&?s04-1&*9=)-%))-$("&;DQ-Q+ Q $ Q 7 Q'Q#Q&Q"Q Q9Q QQrsr&c b\rSrSr\\\\\SSSS\S. SSjjrSrg)r'Nr@c # Xp[X5up[[XX4U5S//5n [[ [ [ [4U 5S//S9nSS0U=(d 0EnURURS5U U[XxXS9[S9IShvN nU(aS S KJnJn U"X5nU"UUS U5 U$N(![an[U5 eSnAff=f7f) zFAsync mirror of `ParseResource.run`. See there for full documentation.r,rGrIrJrKrLrMNrrQrTrUrZs r<raAsyncParseResource.runs"4<0!=h!U" heh O\N d73;#7> |nU')>X=CVTVX  :: [),"/U_(&F  F*+<TH 7Hgv > #  !# &  s<AC"1B>B<B>$C<B>> C CCCrcrdrmrcrsr<r'r's04-1&*9=)-%))-$("&;D+-++ + $ + 7 +'+#+&+"+ +9+ ++rsr'c \rSrSr\\\\\\\SSS\S. S SjjrSSS\S.SSjjr\\\SSS\S.SSjjr\ SS SS .SS jjr S r g)r(N r,r-r.r/r+output_save_url service_tierrBrCrDrEc [XX4U5n [U5(aUbXlS'[U5(aUbX|S'[U S//5n [[ [ [ [4U 5S//S9n SS0U=(d 0EnURURS5U U [XXS9[ S [5S 9n[[ [ [ [4U55$) aCreate an asynchronous parse job against `/v2/parse/jobs`. Returns a normalized `Job` immediately (typically `pending`). Poll for completion via `.get(job_id)`, or block until the job is terminal with `.wait(job_id)`. Args: document: A file to be parsed. Either this parameter or `document_url` must be provided. document_url: The URL to the file to be parsed. Either this parameter or `document` must be provided. model: The version of the model to use for parsing. options: Additional parsing options. Sent to the server as a JSON-encoded string form field. password: Password for encrypted document files. Sent to the server as `options.password` (an explicit `options["password"]` takes precedence) and, for older gateways, as a top-level form field. output_save_url: If zero data retention (ZDR) is enabled, a URL the parsed output should be saved to instead of being returned in the job result. service_tier: Service tier for the job: ``standard`` or ``priority``. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds r{r|r,rGrIrJ/v2/parse/jobsrL type[Any]rM r=rrrrrr1rVrWrXr#rrr[r,r-r.r/r+r{r|rBrCrDrErNrOraws r<createParseJobsResource.createsf!R O $ $)D&5" # L ! !l&>#/ "4:,8d73;#7> |nU')>X=CVTVX jj LL) *(+Q[f- #4S(93#?@@rsrLc U(d[SU<35eURURSU35[X#XES9[ S[ 5S9n[ [ [[[4U55$)z9Get the current status of an async parse job by `job_id`.5Expected a non-empty value for `job_id` but received /v2/parse/jobs/rLrr/rP ValueError_getrXr#rrVrrr1rr[job_idrBrCrDrErs r<getParseJobsResource.get syTU[T^_` `ii LL?6(3 4(+Q[f-  #4S(93#?@@rspage page_sizestatusrBrCrDrEc tXUS.R5VV s0sHup[U 5(dMU cMX_M n nn URURS5[ UUUUU S9[ S[ 5S9n [ [[[4U 5n U RS/5V s/sH)n [[ [[[4U 55PM+ nn [R"UU RS5U RS5U RS 5U RS 5S 9$s sn nfs sn f) zAList async parse jobs associated with your API key, newest first.rrrr~rBrCrDrEqueryrrjobshas_moreorg_idrrrrrrr7rrrXr#rrVrr1rrrr buildr[rrrrBrCrDrEr:r;rrenvitemrs r<listParseJobsResource.lists*(,vV\\^ ^  #( CJ^  ii LL) *(+'% f-  738$c*ORwwW]_aObcObt#Dc):D$ABObc}} WWZ(778$ggk*   % "dsD/D/D/)0D5FrE poll_intervalraise_on_failure _monotonicc n^^[UU4SjU=(d [RTRUUUS9$)aBlock, polling `.get(job_id)` with backoff, until the job is terminal. Raises `JobWaitTimeoutError` if `timeout` seconds elapse before the job reaches a terminal state, and `JobFailedError` if `raise_on_failure` is set and the job ends failed/cancelled with an error attached. `_monotonic` is a test seam for injecting a fake clock; production callers should leave it unset (defaults to `time.monotonic`). c&>TRT5$Nrrr[sr<(ParseJobsResource.wait..XDHHV$rs) monotonicsleeprErr)rtimer_sleepr[rrErrrs`` r<waitParseJobsResource.waitEs1$# $ 2DNN++'-   rsrcr,rer-rfr.rfr/rgr+rfr{rfr|z0Optional[Literal['standard', 'priority']] | OmitrBrhrCrirDrjrErkrlr rr1rBrhrCrirDrjrErkrlrr int | OmitrrrrfrBrhrCrirDrjrErkrlr rr1rEfloatrzOptional[float]rboolrzOptional[Callable[[], float]]rlr rnrorprqrrrrrr rrrrcrsr<r(r(s04-1&*9=)-04IM)-$("&;DDA-DA+ DA $ DA 7 DA'DA.DAGDA&DA"DA DA9DA !DAT)-$("&;DAA& A " A  A9A A0 $'+(,$("&;D$ $  $ % $ & $ "$  $ 9$  $ T.)-!&48    '    2    rsr(c \rSrSr\\\\\\\SSS\S. S SjjrSSS\S.SSjjr\\\SSS\S.SSjjr\ SS SS .SS jjr S r g)r)iaNrzc # [XX4U5n [U5(aUbXlS'[U5(aUbX|S'[U S//5n [[ [ [ [4U 5S//S9n SS0U=(d 0EnURURS5U U [XXS 9[ S [5S 9IShvN n[[ [ [ [4U55$N*7f) zMAsync mirror of `ParseJobsResource.create`. See there for full documentation.Nr{r|r,rGrIrJr~rLrrMrrs r<rAsyncParseJobsResource.createbs$!R O $ $)D&5" # L ! !l&>#/ "4:,8d73;#7> |nU')>X=CVTVX JJ LL) *(+Q[f-  #4S(93#?@@ sB;C*=C(>+C*rLc # U(d[SU<35eURURSU35[X#XES9[ S[ 5S9IShvN n[ [ [[[4U55$N*7f)zJAsync mirror of `ParseJobsResource.get`. See there for full documentation.rrrLrrNrrs r<rAsyncParseJobsResource.getsTU[T^_` `II LL?6(3 4(+Q[f-   #4S(93#?@@ sABB+Brc # XUS.R5VV s0sHup[U 5(dMU cMX_M n nn URURS5[ UUUUU S9[ S[ 5S9IShvN n [ [[[4U 5n U RS/5V s/sH)n [[ [[[4U 55PM+ nn [R"UU RS5U RS 5U RS 5U RS 5S 9$s sn nfNs sn f7f) zKAsync mirror of `ParseJobsResource.list`. See there for full documentation.rNr~rrrrrrrrrrrs r<rAsyncParseJobsResource.lists7(,vV\\^ ^  #( CJ^  II LL) *(+'% f-   738$c*ORwwW]_aObcObt#Dc):D$ABObc}} WWZ(778$ggk*   %  ds8ED9D9D9?E=D?>5E30E#AEEFrct^^# [UU4SjU=(d [RUUUS9IShvN $N7f)zWAsync mirror of `ParseJobsResource.wait`; sleeps via `anyio.sleep` instead of blocking.c&>TRT5$rrrsr<r-AsyncParseJobsResource.wait..rrs)rrErrN)rrrrs`` r<rAsyncParseJobsResource.waits7* $ 2DNN'-     s -868rcrrrrrrcrsr<r)r)as04-1&*9=)-04IM)-$("&;D#A-#A+ #A $ #A 7 #A'#A.#AG#A&#A"#A #A9#A !#AR)-$("&;DAA& A " A  A9A A0 $'+(,$("&;D$ $  $ % $ & $ "$  $ 9$  $ T.)-!&48    '    2    rsr)) r,rVr-rVr.rVr/rVr+rVrlzdict[str, Any])9 __future__rr3rtypingrrrrrpathlibr typing_extensionsr httpx_baser r rrr_filesr_typesrrrrrrrr_utilsrrtypes.v2rr _normalizer _resourcer r! _exceptionsr" _base_clientr# lib.url_utilsr$ lib.v2_errorsr%__all__r=r&r'r(r)rcrsr<rs" 99% ll)VVV-,+:)092 `!d!d!d !d !d  !d  !dHRO_Rj,*:,^[ [ |q _.>q rs