ó
    ­[j#H  ã                  ó€  • S SK Jr  S SKJrJrJrJr  S SKJr  S SK	r	SSK
JrJr  SSKJr  SSKJrJrJrJrJrJrJrJr  SS	KJrJrJrJr  SS
KJr  SSKJ r J!r!  SSK"J#r#J$r$J%r%J&r&  SSK'J(r(  SSK)J*r*  SSK+J,r,  SSK-J.r.  SS/r/ " S S\ 5      r0 " S S\!5      r1 " S S5      r2 " S S5      r3 " S S5      r4 " S S5      r5g)é    )Úannotations)ÚUnionÚMappingÚOptionalÚcast)ÚLiteralNé   )Úextract_job_list_paramsÚextract_job_create_params)Údeepcopy_with_paths)ÚBodyÚOmitÚQueryÚHeadersÚNotGivenÚ	FileTypesÚomitÚ	not_given)Úextract_filesÚpath_templateÚmaybe_transformÚasync_maybe_transform)Úcached_property)ÚSyncAPIResourceÚAsyncAPIResource)Úto_raw_response_wrapperÚto_streamed_response_wrapperÚasync_to_raw_response_wrapperÚ"async_to_streamed_response_wrapper)Úmake_request_options)ÚExtractJobGetResponse)ÚExtractJobListResponse)ÚExtractJobCreateResponseÚExtractJobsResourceÚAsyncExtractJobsResourcec            
      óò   • \ rS rSr\SS j5       r\SS j5       r\\\\\SSS\S.	                     SS jjr	\\\SSS\S.               SS jjr
SSS\S	.           SS
 jjrSrg)r$   é   c                ó   • [        U 5      $ ©zð
This property can be used as a prefix for any HTTP method call to return
the raw response object instead of the parsed content.

For more information, see https://www.github.com/landing-ai/ade-python#accessing-raw-response-data-eg-headers
)Ú"ExtractJobsResourceWithRawResponse©Úselfs    Úa/home/mande/repo/quber/.venv/lib/python3.13/site-packages/landingai_ade/resources/extract_jobs.pyÚwith_raw_responseÚ%ExtractJobsResource.with_raw_response   s   € ô 2°$Ó7Ð7ó    c                ó   • [        U 5      $ ©zµ
An alternative to `.with_raw_response` that doesn't eagerly read the response body.

For more information, see https://www.github.com/landing-ai/ade-python#with_streaming_response
)Ú(ExtractJobsResourceWithStreamingResponser+   s    r-   Úwith_streaming_responseÚ+ExtractJobsResource.with_streaming_response'   s   € ô 8¸Ó=Ð=r0   N©	ÚmarkdownÚmarkdown_urlÚmodelÚoutput_save_urlÚstrictÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutc       
        ó  • [        UUUUUUS.S//5      n[        [        [        [        [
        4   U5      S//S9nSS0U=(       d    0 EnU R                  S[        U[        R                  5      U[        XxXšS9[        S9$ )	áQ  
Extract structured data asynchronously.

This endpoint creates a job that handles the processing for large markdown
documents.

For EU users, use this endpoint:

`https://api.va.eu-west-1.landing.ai/v1/ade/extract/jobs`.

Args:
  schema: JSON schema for field extraction. This schema determines what key-values pairs
      are extracted from the Markdown. The schema must be a valid JSON object and will
      be validated before processing the document.

  markdown: The Markdown file or Markdown content to extract data from.

  markdown_url: The URL to the Markdown file to extract data from.

  model: The version of the model to use for extraction. Use `extract-latest` to use the
      latest version.

  output_save_url: If zero data retention (ZDR) is enabled, you must enter a URL for the extracted
      output to be saved to. When ZDR is enabled, the extracted content will not be in
      the API response.

  strict: If True, reject schemas with unsupported fields (HTTP 422). If False, prune
      unsupported fields and continue. Only applies to extract versions that support
      schema validation.

  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
©Úschemar7   r8   r9   r:   r;   r7   ©ÚpathsúContent-Typeúmultipart/form-dataú/v1/ade/extract/jobs©r<   r=   r>   r?   ©ÚbodyÚfilesÚoptionsÚcast_to)r   r   r   r   ÚstrÚobjectÚ_postr   r   ÚExtractJobCreateParamsr    r#   ©r,   rC   r7   r8   r9   r:   r;   r<   r=   r>   r?   rK   rL   s                r-   ÚcreateÚExtractJobsResource.create0   s©   € ôl #à Ø$Ø ,ØØ#2Ø ñð ˆ\ˆNó

ˆô œd¤7¬3´¨;Ñ#7¸Ó>È
À|ÀnÑUˆð (Ð)>ÐXÀ=×CVÐTVÐXˆØ�z‰zØ"Ü  Ô'@×'WÑ'WÓXØÜ(Ø+ÐQ[ñô -ð ð 
ð 	
r0   ©ÚpageÚ	page_sizeÚstatusr<   r=   r>   r?   c               óz   • U R                  S[        UUUU[        UUUS.[        R                  5      S9[
        S9$ )á*  List all async extract jobs associated with your API key.

Returns the list of
jobs or an error response. For EU users, use this endpoint:

`https://api.va.eu-west-1.landing.ai/v1/ade/extract/jobs`.

Args:
  page: Page number (0-indexed)

  page_size: Number of items per page

  status: Filter by job status.

  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
rH   ©rW   rX   rY   ©r<   r=   r>   r?   Úquery©rM   rN   )Ú_getr    r   r
   ÚExtractJobListParamsr"   ©r,   rW   rX   rY   r<   r=   r>   r?   s           r-   ÚlistÚExtractJobsResource.list€   sX   € ðF �y‰yØ"Ü(Ø+Ø'Ø%ØÜ%à $Ø%.Ø"(ñô
 ,×@Ñ@óñô +ð! ð 
ð 	
r0   rI   c          
     óx   • U(       d  [        SU< 35      eU R                  [        SUS9[        X#XES9[        S9$ )á¸  
Get the status for an async extract job.

Returns the job status or an error response. For EU users, use this endpoint:

`https://api.va.eu-west-1.landing.ai/v1/ade/extract/jobs/{job_id}`.

Args:
  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
ú5Expected a non-empty value for `job_id` but received ú/v1/ade/extract/jobs/{job_id}©Újob_idrI   r_   ©Ú
ValueErrorr`   r   r    r!   ©r,   rj   r<   r=   r>   r?   s         r-   ÚgetÚExtractJobsResource.get¶   sP   € ö6 ÜÐTÐU[ÑT^Ð_Ó`Ð`Ø�y‰yÜÐ9À&ÑIÜ(Ø+ÐQ[ñô *ð ð 
ð 	
r0   © )Úreturnr*   )rq   r3   ©rC   rO   r7   z"Union[FileTypes, str, None] | Omitr8   úOptional[str] | Omitr9   rs   r:   rs   r;   zbool | Omitr<   úHeaders | Noner=   úQuery | Noner>   úBody | Noner?   ú'float | httpx.Timeout | None | NotGivenrq   r#   ©rW   ú
int | OmitrX   ry   rY   zUOptional[Literal['cancelled', 'completed', 'failed', 'pending', 'processing']] | Omitr<   rt   r=   ru   r>   rv   r?   rw   rq   r"   ©rj   rO   r<   rt   r=   ru   r>   rv   r?   rw   rq   r!   ©Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r.   r4   r   r   rT   rc   rn   Ú__static_attributes__rp   r0   r-   r$   r$      s‰  † Øó8ó ð8ð ó>ó ð>ð 8<Ø-1Ø&*Ø04Ø"ð )-Ø$(Ø"&Ø;DñN
ð ðN
ð 5ð	N
ð
 +ðN
ð $ðN
ð .ðN
ð ðN
ð &ðN
ð "ðN
ð  ðN
ð 9ðN
ð 
"õN
ðf  Ø $Øhlð )-Ø$(Ø"&Ø;Dñ4
ð ð4
ð ð	4
ð
 fð4
ð &ð4
ð "ð4
ð  ð4
ð 9ð4
ð 
 õ4
ðx )-Ø$(Ø"&Ø;Dñ#
àð#
ð &ð#
ð "ð#
ð  ð#
ð 9ð#
ð 
÷#
ð #
r0   c            
      óò   • \ rS rSr\SS j5       r\SS j5       r\\\\\SSS\S.	                     SS jjr	\\\SSS\S.               SS jjr
SSS\S	.           SS
 jjrSrg)r%   éÜ   c                ó   • [        U 5      $ r)   )Ú'AsyncExtractJobsResourceWithRawResponser+   s    r-   r.   Ú*AsyncExtractJobsResource.with_raw_responseÝ   s   € ô 7°tÓ<Ð<r0   c                ó   • [        U 5      $ r2   )Ú-AsyncExtractJobsResourceWithStreamingResponser+   s    r-   r4   Ú0AsyncExtractJobsResource.with_streaming_responseç   s   € ô =¸TÓBÐBr0   Nr6   c       
      ƒ  ó6  #   • [        UUUUUUS.S//5      n[        [        [        [        [
        4   U5      S//S9nSS0U=(       d    0 EnU R                  S[        U[        R                  5      I Sh  v•N U[        XxXšS9[        S	9I Sh  v•N $  N N7f)
rA   rB   r7   rD   rF   rG   rH   NrI   rJ   )r   r   r   r   rO   rP   rQ   r   r   rR   r    r#   rS   s                r-   rT   ÚAsyncExtractJobsResource.createð   s¼   é € ôl #à Ø$Ø ,ØØ#2Ø ñð ˆ\ˆNó

ˆô œd¤7¬3´¨;Ñ#7¸Ó>È
À|ÀnÑUˆð (Ð)>ÐXÀ=×CVÐTVÐXˆØ—Z‘ZØ"Ü,¨TÔ3L×3cÑ3cÓd×dØÜ(Ø+ÐQ[ñô -ð  ð 
÷ 
ð 	
ádñ
ùs$   ‚A5BÁ7B
Á8BÂBÂBÂBrV   c             ƒ  óª   #   • U R                  S[        UUUU[        UUUS.[        R                  5      I Sh  v•N S9[
        S9I Sh  v•N $  N N7f)r[   rH   r\   Nr]   r_   )r`   r    r   r
   ra   r"   rb   s           r-   rc   ÚAsyncExtractJobsResource.list@  so   é € ðF —Y‘YØ"Ü(Ø+Ø'Ø%ØÜ1à $Ø%.Ø"(ñô
 ,×@Ñ@ó÷ ñô +ð! ð 
÷ 
ð 	
ññ
ùs!   ‚7A¹AºAÁ
AÁAÁArI   c          
   ƒ  ó”   #   • U(       d  [        SU< 35      eU R                  [        SUS9[        X#XES9[        S9I Sh  v•N $  N7f)rf   rg   rh   ri   rI   r_   Nrk   rm   s         r-   rn   ÚAsyncExtractJobsResource.getv  s]   é € ö6 ÜÐTÐU[ÑT^Ð_Ó`Ð`Ø—Y‘YÜÐ9À&ÑIÜ(Ø+ÐQ[ñô *ð ð 
÷ 
ð 	
ñ 
ùs   ‚?AÁAÁArp   )rq   r„   )rq   r‡   rr   rx   rz   r{   rp   r0   r-   r%   r%   Ü   s‹  † Øó=ó ð=ð óCó ðCð 8<Ø-1Ø&*Ø04Ø"ð )-Ø$(Ø"&Ø;DñN
ð ðN
ð 5ð	N
ð
 +ðN
ð $ðN
ð .ðN
ð ðN
ð &ðN
ð "ðN
ð  ðN
ð 9ðN
ð 
"õN
ðf  Ø $Øhlð )-Ø$(Ø"&Ø;Dñ4
ð ð4
ð ð	4
ð
 fð4
ð &ð4
ð "ð4
ð  ð4
ð 9ð4
ð 
 õ4
ðx )-Ø$(Ø"&Ø;Dñ#
àð#
ð &ð#
ð "ð#
ð  ð#
ð 9ð#
ð 
÷#
ð #
r0   c                  ó   • \ rS rSrSS jrSrg)r*   iœ  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g ©N)Ú_extract_jobsr   rT   rc   rn   ©r,   Úextract_jobss     r-   Ú__init__Ú+ExtractJobsResourceWithRawResponse.__init__�  sK   € Ø)Ôä-Ø×Ñó
ˆŒô ,Ø×Ñó
ˆŒ	ô +Ø×Ñó
ˆ�r0   ©r’   rT   rn   rc   N©r”   r$   rq   ÚNone©r|   r}   r~   r   r•   r€   rp   r0   r-   r*   r*   œ  ó   † ÷
r0   r*   c                  ó   • \ rS rSrSS jrSrg)r„   i«  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g r‘   )r’   r   rT   rc   rn   r“   s     r-   r•   Ú0AsyncExtractJobsResourceWithRawResponse.__init__¬  sK   € Ø)Ôä3Ø×Ñó
ˆŒô 2Ø×Ñó
ˆŒ	ô 1Ø×Ñó
ˆ�r0   r—   N©r”   r%   rq   r™   rš   rp   r0   r-   r„   r„   «  r›   r0   r„   c                  ó   • \ rS rSrSS jrSrg)r3   iº  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g r‘   )r’   r   rT   rc   rn   r“   s     r-   r•   Ú1ExtractJobsResourceWithStreamingResponse.__init__»  sK   € Ø)Ôä2Ø×Ñó
ˆŒô 1Ø×Ñó
ˆŒ	ô 0Ø×Ñó
ˆ�r0   r—   Nr˜   rš   rp   r0   r-   r3   r3   º  r›   r0   r3   c                  ó   • \ rS rSrSS jrSrg)r‡   iÉ  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g r‘   )r’   r   rT   rc   rn   r“   s     r-   r•   Ú6AsyncExtractJobsResourceWithStreamingResponse.__init__Ê  sK   € Ø)Ôä8Ø×Ñó
ˆŒô 7Ø×Ñó
ˆŒ	ô 6Ø×Ñó
ˆ�r0   r—   NrŸ   rš   rp   r0   r-   r‡   r‡   É  r›   r0   r‡   )6Ú
__future__r   Útypingr   r   r   r   Útyping_extensionsr   ÚhttpxÚtypesr
   r   Ú_filesr   Ú_typesr   r   r   r   r   r   r   r   Ú_utilsr   r   r   r   Ú_compatr   Ú	_resourcer   r   Ú	_responser   r   r   r   Ú_base_clientr    Útypes.extract_job_get_responser!   Útypes.extract_job_list_responser"   Ú!types.extract_job_create_responser#   Ú__all__r$   r%   r*   r„   r3   r‡   rp   r0   r-   Ú<module>r¶      s™   ðÝ "ç 1Ó 1Ý %ã ç FÝ (ß U× UÓ Uß YÓ YÝ %ß 9÷ó õ 0Ý BÝ DÝ Hà Ð"<Ð
=€ô}
˜/ô }
ô@}
Ð/ô }
÷@
ñ 
÷
ñ 
÷
ñ 
÷
ò 
r0   