Ë
    ²ŒjóR  ã                   ó¢  — d dl Z d dlZd dlZd dlmZ d dlmZmZmZm	Z	m
Z
mZmZmZmZmZmZ d dlZd dlmZmZmZ d dlmZmZ d dlmZ d dlmZmZ d dlmZ d d	l m!Z!m"Z" d d
l#m$Z$ d dl%m&Z& 	 d dl'm(Z' erd dl*m+Z+ d dl,m-Z- d dl.m/Z/ d dl#m0Z0  G d„ de"«      Z1 G d„ de!«      Z2 G d„ de«      Z3deee4e5f      de3fd„Z6ddœdeee4e5f      deejn                  df   fd„Z8ddœdeee4e5f      de	e9ef   fd„Z:	 	 	 	 d(deee&e9f      dee	e9ef      dee9   d ee9   d!eee9      d"ee5   de	e9ef   fd#„Z;d$d%d&e	e9ef   de1fd'„Z<y# e)$ r d dl'Z'Y ŒÛw xY w))é    N)Ú	dataclass)ÚTYPE_CHECKINGÚAnyÚAsyncIteratorÚDictÚIteratorÚListÚLiteralÚOptionalÚTupleÚUnionÚoverload)ÚNotRequiredÚ	TypedDictÚUnpack)Ú
ModelErrorÚReplicateError)ÚFileEncodingStrategy)Úasync_encode_jsonÚencode_json)ÚPage)Ú	NamespaceÚResource)ÚEventSource)ÚVersion)Úv1)ÚClient)Ú
Deployment)ÚModel)ÚServerSentEventc                   ó  — e Zd ZU dZ ej
                  «       Zded<   eed<   	 eed<   	 eed<   	 e	d   ed<   	 e
eeef      ed	<   	 e
e   ed
<   	 e
e   ed<   	 e
e   ed<   	 e
eeef      ed<   	 e
e   ed<   	 e
e   ed<   	 e
e   ed<   	 e
eeef      ed<   	 e G d„ d«      «       Zede
e   fd„«       Zd#d„Zd#d„Z	 d$de
e   ded   fd„Z	 d$de
e   ded   fd„Zd#d„Zd#d„Zd#d„Zd#d „Zdee   fd!„Zdee   fd"„Zy)%Ú
Predictionz;
    A prediction made by a model hosted on Replicate.
    r   Ú_clientÚidÚmodelÚversion)ÚstartingÚ
processingÚ	succeededÚfailedÚcanceledÚstatusÚinputÚoutputÚlogsÚerrorÚmetricsÚ
created_atÚ
started_atÚcompleted_atÚurlsc                   óz   — e Zd ZU dZeed<   	 eed<   	 eed<   	  ej                  d«      Z	e
deded    fd„«       Zy	)
úPrediction.Progressz/
        The progress of a prediction.
        Ú
percentageÚcurrentÚtotalzE^\s*(?P<percentage>\d+)%\s*\|.+?\|\s*(?P<current>\d+)\/(?P<total>\d+)r/   Úreturnc                 óf  — |j                  d«      }t        t        t        |«      «      «      D ]€  }||   j	                  «       }| j
                  j                  |«      sŒ2| j
                  j                  |«      }t        |«      dk(  sŒ\t        t        |d   «      \  }}} | |dz  ||«      c S  y)z1Parse the progress from the logs of a prediction.Ú
é   r   g      Y@N)
ÚsplitÚreversedÚrangeÚlenÚstripÚ_patternÚmatchÚfindallÚmapÚint)	Úclsr/   ÚlinesÚidxÚlineÚmatchesr8   r9   r:   s	            ú^/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/replicate/prediction.pyÚparsezPrediction.Progress.parseq   sž   € ð —J‘J˜tÓ$ˆEÜ¤¤c¨%£jÓ 1Ö2�Ø˜S‘z×'Ñ'Ó)�Ø—<‘<×%Ñ% dÕ+Ø!Ÿl™l×2Ñ2°4Ó8�GÜ˜7“| qÓ(Ü58¼¸gÀa¹jÓ5IÑ2˜
 G¨UÙ" :°Ñ#5°wÀÓFÒFð 3ð ó    N)Ú__name__Ú
__module__Ú__qualname__Ú__doc__ÚfloatÚ__annotations__rH   ÚreÚcompilerD   ÚclassmethodÚstrr   rO   © rP   rN   ÚProgressr7   ^   s]   … ñ	ð ÓØBà‹Ø;à‹
Ø3à�2—:‘:ØTó
ˆð 
ð	˜Sð 	 XÐ.CÑ%Dò 	ó 
ñ	rP   r\   r;   c                 óŒ   — | j                   �| j                   dk(  ryt        j                  j                  | j                   «      S )z?
        The progress of the prediction, if available.
        NÚ )r/   r"   r\   rO   ©Úselfs    rN   ÚprogresszPrediction.progress€   s6   € ð �9‰9Ð §	¡	¨R¢Øä×"Ñ"×(Ñ(¨¯©Ó3Ð3rP   Nc                 ó²   — | j                   dvrIt        j                  | j                  j                  «       | j                  «        | j                   dvrŒHyy)z0
        Wait for prediction to finish.
        ©r)   r*   r+   N)r,   ÚtimeÚsleepr#   Úpoll_intervalÚreloadr_   s    rN   ÚwaitzPrediction.wait‹   s?   € ð
 �k‰kÐ!DÑDÜ�J‰J�t—|‘|×1Ñ1Ô2Ø�K‰KŒMð �k‰kÐ!DÔDrP   c              ƒ   óâ   K  — | j                   dvrYt        j                  | j                  j                  «      ƒ d{  –—†  | j                  «       ƒ d{  –—†  | j                   dvrŒXyy7 Œ-7 Œ­w)z?
        Wait for prediction to finish asynchronously.
        rc   N)r,   Úasynciore   r#   rf   Úasync_reloadr_   s    rN   Ú
async_waitzPrediction.async_wait”   sY   è ø€ ð
 �k‰kÐ!DÑDÜ—-‘- §¡× :Ñ :Ó;×;Ð;Ø×#Ñ#Ó%×%Ð%ð �k‰kÐ!DÔDØ;øØ%ús'   ‚;A/½A+¾A/ÁA-ÁA/Á)A/Á-A/Úuse_file_outputr    c              #   óp  K  — | j                   xr | j                   j                  dd«      }|rt        |t        «      st	        d«      ‚i }d|d<   d|d<   | j
                  j
                  j                  d||¬	«      5 }t        | j
                  ||¬
«      E d{  –—†  ddd«       y7 Œ# 1 sw Y   yxY w­w)z…
        Stream the prediction output.

        Raises:
            ReplicateError: If the model does not support streaming.
        ÚstreamNú Model does not support streamingútext/event-streamÚAcceptúno-storeúCache-ControlÚGET©Úheaders©rm   )r5   ÚgetÚ
isinstancerZ   r   r#   ro   r   )r`   rm   Úurlrw   Úresponses        rN   ro   zPrediction.stream�   s¬   è ø€ ð �i‰iÒ9˜DŸI™IŸM™M¨(°DÓ9ˆÙœ* S¬#Ô.Ü Ð!CÓDÐDàˆØ/ˆ�ÑØ#-ˆ�Ñ à�\‰\×!Ñ!×(Ñ(¨°¸WÐ(ÔEÈÜ"Ø—‘˜h¸ô÷ ð ÷ FÐEðø÷ FÐEüs0   ‚A<B6Á>B*ÂB(ÂB*Â	B6Â(B*Â*B3Â/B6c                óö  K  — t        j                  d«      ƒ d{  –—†  | j                  xr | j                  j                  dd«      }|rt	        |t
        «      st        d«      ‚i }d|d<   d|d<   | j                  j                  j                  d	||¬
«      4 ƒd{  –—† }t        | j                  ||¬«      2 3 d{  –—† }|­–— Œ7 Œ¯7 Œ-7 Œ6 ddd«      ƒd{  –—†7   y# 1 ƒd{  –—†7  sw Y   yxY w­w)z”
        Stream the prediction output asynchronously.

        Raises:
            ReplicateError: If the model does not support streaming.
        r   Nro   rp   rq   rr   rs   rt   ru   rv   rx   )rj   re   r5   ry   rz   rZ   r   r#   Ú_async_clientro   r   )r`   rm   r{   rw   r|   Úevents         rN   Úasync_streamzPrediction.async_streamµ   så   è ø€ ô �m‰m˜AÓ×Ðà�i‰iÒ9˜DŸI™IŸM™M¨(°DÓ9ˆÙœ* S¬#Ô.Ü Ð!CÓDÐDàˆØ/ˆ�ÑØ#-ˆ�Ñ à—<‘<×-Ñ-×4Ñ4Ø�3 ð 5÷ 
ô 
àÜ*Ø—‘˜h¸õ ÷ �eð ”ð! 	øð
øðøð  ÷
÷ 
÷ 
÷ 
ó 
üs|   ‚C9›CœBC9ÂCÂ C9Â#C$Â<CÃ CÃCÃC$ÃC9ÃC9ÃCÃC$ÃC9ÃC ÃC9Ã$C6Ã*C-Ã+C6Ã2C9c                 óÈ   — | j                   j                  j                  | j                  «      }|j	                  «       j                  «       D ]  \  }}t        | ||«       Œ y)z/
        Cancels a running prediction.
        N)r#   ÚpredictionsÚcancelr$   ÚdictÚitemsÚsetattr©r`   r+   ÚnameÚvalues       rN   rƒ   zPrediction.cancelÓ   sK   € ð
 —<‘<×+Ñ+×2Ñ2°4·7±7Ó;ˆØ#Ÿ=™=›?×0Ñ0Ö2‰KˆD�%Ü�D˜$ Õ&ñ 3rP   c              ƒ   óä   K  — | j                   j                  j                  | j                  «      ƒ d{  –—† }|j	                  «       j                  «       D ]  \  }}t        | ||«       Œ y7 Œ8­w)z>
        Cancels a running prediction asynchronously.
        N)r#   r‚   Úasync_cancelr$   r„   r…   r†   r‡   s       rN   r‹   zPrediction.async_cancelÜ   sX   è ø€ ð
 Ÿ™×1Ñ1×>Ñ>¸t¿w¹wÓG×GˆØ#Ÿ=™=›?×0Ñ0Ö2‰KˆD�%Ü�D˜$ Õ&ñ 3ð Húó   ‚3A0µA.¶9A0c                 óÈ   — | j                   j                  j                  | j                  «      }|j	                  «       j                  «       D ]  \  }}t        | ||«       Œ y)z7
        Load this prediction from the server.
        N)r#   r‚   ry   r$   r„   r…   r†   ©r`   Úupdatedrˆ   r‰   s       rN   rg   zPrediction.reloadå   sK   € ð
 —,‘,×*Ñ*×.Ñ.¨t¯w©wÓ7ˆØ"Ÿ<™<›>×/Ñ/Ö1‰KˆD�%Ü�D˜$ Õ&ñ 2rP   c              ƒ   óä   K  — | j                   j                  j                  | j                  «      ƒ d{  –—† }|j	                  «       j                  «       D ]  \  }}t        | ||«       Œ y7 Œ8­w)zF
        Load this prediction from the server asynchronously.
        N)r#   r‚   Ú	async_getr$   r„   r…   r†   rŽ   s       rN   rk   zPrediction.async_reloadî   sX   è ø€ ð
 Ÿ™×0Ñ0×:Ñ:¸4¿7¹7ÓC×CˆØ"Ÿ<™<›>×/Ñ/Ö1‰KˆD�%Ü�D˜$ Õ&ñ 2ð DúrŒ   c              #   ó¸  K  — | j                   xs g }| j                  dvrr| j                   xs g }|t        |«      d }|E d{  –—†  |}t        j                  | j
                  j                  «       | j                  «        | j                  dvrŒr| j                  dk(  rt        | «      ‚| j                   xs g }|t        |«      d }|E d{  –—†  y7 Œ‘7 Œ­w)z>
        Return an iterator of the prediction output.
        rc   Nr*   )	r.   r,   rB   rd   re   r#   rf   rg   r   )r`   Úprevious_outputr.   Ú
new_outputs       rN   Úoutput_iteratorzPrediction.output_iterator÷   sÌ   è ø€ ð Ÿ+™+Ò+¨ˆØ�k‰kÐ!DÑDØ—[‘[Ò& BˆFØ¤ OÓ 4Ð 6Ð7ˆJØ!×!Ð!Ø$ˆOÜ�J‰J�t—|‘|×1Ñ1Ô2Ø�K‰KŒMð �k‰kÐ!DÒDð �;‰;˜(Ò"Ü˜TÓ"Ð"à—‘Ò" ˆØœC Ó0Ð2Ð3ˆ
Ø×Ñð "øð 	ús+   ‚ACÁCÁACÂ=CÃCÃCÃCc                óà  K  — | j                   xs g }| j                  dvr„| j                   xs g }|t        |«      d }|D ]  }|­–— Œ	 |}t        j                  | j
                  j                  «      ƒ d{  –—†  | j                  «       ƒ d{  –—†  | j                  dvrŒ„| j                  dk(  rt        | «      ‚| j                   xs g }|t        |«      d }|D ]  }|­–— Œ	 y7 Œp7 ŒZ­w)zK
        Return an asynchronous iterator of the prediction output.
        rc   Nr*   )	r.   r,   rB   rj   re   r#   rf   rk   r   )r`   r“   r.   r”   Úitems        rN   Úasync_output_iteratorz Prediction.async_output_iterator  så   è ø€ ð Ÿ+™+Ò+¨ˆØ�k‰kÐ!DÑDØ—[‘[Ò& BˆFØ¤ OÓ 4Ð 6Ð7ˆJÛ"�Ø”
ð #à$ˆOÜ—-‘- §¡× :Ñ :Ó;×;Ð;Ø×#Ñ#Ó%×%Ð%ð �k‰kÐ!DÒDð �;‰;˜(Ò"Ü˜TÓ"Ð"à—‘Ò" ˆØœC Ó0Ð2Ð3ˆ
Û ˆFØŒLñ !ð <øØ%ús+   ‚A7C.Á9C*Á:C.ÂC,ÂC.Â%AC.Ã,C.)r;   N©N)rQ   rR   rS   rT   ÚpydanticÚPrivateAttrr#   rV   rZ   r
   r   r   r   r   r\   Úpropertyra   rh   rl   Úboolr   ro   r   r€   rƒ   r‹   rg   rk   r•   r˜   r[   rP   rN   r"   r"   *   sœ  … ñð -˜×,Ñ,Ó.€GˆXÓ.àƒGØ*àƒJØ^àƒLØSàÐOÑPÓPØ'à�D˜˜c˜‘NÑ#Ó#Ø&à�S‰MÓØ'à
�3‰-ÓØ%à�C‰=ÓØ>à�d˜3 ˜8‘nÑ%Ó%Ø%à˜‘ÓØ*à˜‘ÓØ*à˜3‘-ÓØ9à
�4˜˜S˜‘>Ñ
"Ó"ðð ÷ð ó ððB ð4˜( 8Ñ,ò 4ó ð4óó&ð +/ñà! $™ðð 
Ð#Ñ	$óð4 +/ñà! $™ðð 
Ð(Ñ	)óó<'ó'ó'ó'ð ¨#¡ó ð,¨]¸3Ñ-?ô rP   r"   c                   ó„  — e Zd ZdZd!deeddf   dee   fd„Z	 d!deeddf   dee   fd„Z	dedefd	„Z
dedefd
„Z G d„ de«      Zedeeef   deeeef      ded   defd„«       Zedeeeeef   df   deeeef      ded   defd„«       Zedeeeeef   df   deeeef      ded   defd„«       Zdddddœdeeeeeef   df      deeeedf      deeeeeef   df      deeeef      ded   defd„Zedeeef   deeeef      ded   defd„«       Zedeeeeef   df   deeeef      ded   defd„«       Zedeeeeef   df   deeeef      ded   defd„«       Zdddddœdeeeeeef   df      deeeedf      deeeeeef   df      deeeef      ded   defd„Zdedefd„Zdedefd „Zy)"ÚPredictionsz:
    Namespace for operations related to predictions.
    ÚcursorÚellipsisNr;   c                 ó  — |€t        d«      ‚| j                  j                  d|du rdn|«      }|j                  «       }|d   D �cg c]  }t	        | j                  |«      ‘Œ c}|d<   t        t           di |¤ŽS c c}w )á,  
        List your predictions.

        Parameters:
            cursor: The cursor to use for pagination. Use the value of `Page.next` or `Page.previous`.
        Returns:
            Page[Prediction]: A page of of predictions.
        Raises:
            ValueError: If `cursor` is `None`.
        úcursor cannot be Noneru   .ú/v1/predictionsÚresultsr[   )Ú
ValueErrorr#   Ú_requestÚjsonÚ_json_to_predictionr   r"   ©r`   r    ÚrespÚobjÚresults        rN   ÚlistzPredictions.list+  s‹   € ð ˆ>ÜÐ4Ó5Ð5à�|‰|×$Ñ$Ø¨°#©Ñ$¸6ó
ˆð �i‰i‹kˆàDGÈ	ÂNó
ÙDR¸&Ô §¡¨fÕ5ÀNñ
ˆˆI‰ô ”JÑÑ& #Ñ&Ð&ùò	
s   ÁA<c              ƒ   ó  K  — |€t        d«      ‚| j                  j                  d|du rdn|«      ƒ d{  –—† }|j                  «       }|d   D �cg c]  }t	        | j                  |«      ‘Œ c}|d<   t        t           di |¤ŽS 7 ŒPc c}w ­w)r£   Nr¤   ru   .r¥   r¦   r[   )r§   r#   Ú_async_requestr©   rª   r   r"   r«   s        rN   Ú
async_listzPredictions.async_listE  s™   è ø€ ð ˆ>ÜÐ4Ó5Ð5à—\‘\×0Ñ0Ø¨°#©Ñ$¸6ó
÷ 
ˆð �i‰i‹kˆàDGÈ	ÂNó
ÙDR¸&Ô §¡¨fÕ5ÀNñ
ˆˆI‰ô ”JÑÑ& #Ñ&Ð&ð
úò

ùs!   ‚3BµB¶BÁBÁ.BÂBr$   c                 óˆ   — | j                   j                  dd|› �«      }t        | j                   |j                  «       «      S )ú¢
        Get a prediction by ID.

        Args:
            id: The ID of the prediction.
        Returns:
            Prediction: The prediction object.
        ru   ú/v1/predictions/©r#   r¨   rª   r©   ©r`   r$   r¬   s      rN   ry   zPredictions.getb  s9   € ð �|‰|×$Ñ$ UÐ.>¸r¸dÐ,CÓDˆä" 4§<¡<°·±³Ó=Ð=rP   c              ƒ   ó¤   K  — | j                   j                  dd|› �«      ƒ d{  –—† }t        | j                   |j                  «       «      S 7 Œ(­w)r´   ru   rµ   N©r#   r±   rª   r©   r·   s      rN   r‘   zPredictions.async_getp  sF   è ø€ ð —\‘\×0Ñ0°Ð:JÈ2È$Ð8OÓP×Pˆä" 4§<¡<°·±³Ó=Ð=ð Qús   ‚#A¥A¦)Ac                   óŒ   — e Zd ZU dZee   ed<   	 ee   ed<   	 eee      ed<   	 ee   ed<   	 ee	e
ef      ed<   	 ee   ed<   y)	ú"Predictions.CreatePredictionParamsz%Parameters for creating a prediction.ÚwebhookÚwebhook_completedÚwebhook_events_filterro   rh   Úfile_encoding_strategyN)rQ   rR   rS   rT   r   rZ   rV   r	   r�   r   rH   r   r[   rP   rN   ÚCreatePredictionParamsr»   ~  sk   … Ù3à˜SÑ!Ó!ØHà& sÑ+Ó+ØQà*¨4°©9Ñ5Ó5Ø1à˜DÑ!Ó!Ø4à˜%  T 	Ñ*Ñ+Ó+ð	ð !,Ð,@Ñ AÓAØMrP   rÀ   r&   r-   Úparamsr»   c                  ó   — y r™   r[   ©r`   r&   r-   rÁ   s       rN   ÚcreatezPredictions.create›  s   € ð rP   r%   r   c                 ó   — y r™   r[   ©r`   r%   r-   rÁ   s       rN   rÄ   zPredictions.create£  ó   € ð rP   Ú
deploymentr   c                 ó   — y r™   r[   ©r`   rÈ   r-   rÁ   s       rN   rÄ   zPredictions.create¬  rÇ   rP   )r%   r&   rÈ   r-   r   c                ó¾  — |j                  dd«      }|j                  dd«      }|r*t        |«      dkD  r|d   nd}t        |«      dkD  r|d   n|}t        d„ |||fD «       «      dk7  rt        d«      ‚|�9ddlm}	   |	| j                  «      j                  j                  d||xs i d	œ|¤ŽS |�9dd
l	m
}
   |
| j                  «      j                  j                  d||xs i dœ|¤ŽS |�t        || j                  |¬«      }t        ||fi |¤Ž}t        |¬«      } | j                  j                  dd|i|¤Ž}t        | j                  |j!                  «       «      S )úZ
        Create a new prediction for the specified model, version, or deployment.
        rh   Nr¿   r   r>   c              3   ó2   K  — | ]  }t        |«      –— Œ y ­wr™   ©r�   ©Ú.0Úxs     rN   Ú	<genexpr>z%Predictions.create.<locals>.<genexpr>É  ó   è ø€ Ð=Ñ <˜1Œt�A�wÑ <ùó   ‚úEExactly one of 'model', 'version', or 'deployment' must be specified.©ÚModels©r%   r-   ©ÚDeployments©rÈ   r-   ©Úclientr¿   ©rh   r©   r[   ©ÚPOSTr¥   )ÚpoprB   Úsumr§   Úreplicate.modelr×   r#   r‚   rÄ   Úreplicate.deploymentrÚ   r   Ú_create_prediction_bodyÚ!_create_prediction_request_paramsr¨   rª   r©   ©r`   r%   r&   rÈ   r-   ÚargsrÁ   rh   r¿   r×   rÚ   ÚbodyÚextrasr¬   s                 rN   rÄ   zPredictions.createµ  s’  € ð �z‰z˜& $Ó'ˆØ!'§¡Ð,DÀdÓ!KÐáÜ!$ T£¨Q¢�d˜1’g°DˆGÜ" 4›y¨1š}�D˜’G°%ˆEäÑ= ¨°Ñ <Ó=Ó=ÀÒBÜØWóð ð Ðõð ;‘6˜$Ÿ,™,Ó'×3Ñ3×:Ñ:ð ØØ’k˜rñð ñð ð Ð!õð @‘;˜tŸ|™|Ó,×8Ñ8×?Ñ?ð Ø%Ø’k˜rñð ñð ð ÐÜØØ—|‘|Ø'=ôˆEô 'ØØñ
ð ñ
ˆô
 3¸Ô=ˆØ$ˆt�|‰|×$Ñ$ÑTÀTÐTÈVÑTˆä" 4§<¡<°·±³Ó=Ð=rP   c              ‹   ó   K  — y ­wr™   r[   rÃ   s       rN   Úasync_createzPredictions.async_createõ  s   è ø€ ð ùó   ‚c             ‹   ó   K  — y ­wr™   r[   rÆ   s       rN   rì   zPredictions.async_createý  ó   è ø€ ð ùrí   c             ‹   ó   K  — y ­wr™   r[   rÊ   s       rN   rì   zPredictions.async_create  rï   rí   c             �   ó  K  — |j                  dd«      }|j                  dd«      }|r*t        |«      dkD  r|d   nd}t        |«      dkD  r|d   n|}t        d„ |||fD «       «      dk7  rt        d«      ‚|�Addlm}	   |	| j                  «      j                  j                  d||xs i d	œ|¤Žƒ d{  –—† S |�Add
l	m
}
   |
| j                  «      j                  j                  d||xs i dœ|¤Žƒ d{  –—† S |� t        || j                  |¬«      ƒ d{  –—† }t        ||fi |¤Ž}t        |¬«      } | j                  j                  	 dd|i|¤Žƒ d{  –—† }t        | j                  |j!                  «       «      S 7 ŒÍ7 ŒŒ7 Œl7 Œ.­w)rÌ   rh   Nr¿   r   r>   c              3   ó2   K  — | ]  }t        |«      –— Œ y ­wr™   rÎ   rÏ   s     rN   rÒ   z+Predictions.async_create.<locals>.<genexpr>"  rÓ   rÔ   rÕ   rÖ   rØ   rÙ   rÛ   rÜ   rÞ   r©   r[   rß   )rá   rB   râ   r§   rã   r×   r#   r‚   rì   rä   rÚ   r   rå   ræ   r±   rª   r©   rç   s                 rN   rì   zPredictions.async_create  sÐ  è ø€ ð �z‰z˜& $Ó'ˆØ!'§¡Ð,DÀdÓ!KÐáÜ!$ T£¨Q¢�d˜1’g°DˆGÜ" 4›y¨1š}�D˜’G°%ˆEäÑ= ¨°Ñ <Ó=Ó=ÀÒBÜØWóð ð Ðõð G™ §¡Ó-×9Ñ9×FÑFð ØØ’k˜rñð ñ÷ ð ð Ð!õð L™ T§\¡\Ó2×>Ñ>×KÑKð Ø%Ø’k˜rñð ñ÷ ð ð ÐÜ+ØØ—|‘|Ø'=ô÷ ˆEô 'ØØñ
ð ñ
ˆô
 3¸Ô=ˆØ0�T—\‘\×0Ñ0Ø%ñ
Ø,0ð
Ø4:ñ
÷ 
ˆô # 4§<¡<°·±³Ó=Ð=ðEøðøðøð
úsI   ‚B2F
Â4FÂ5AF
Ã7FÃ8!F
ÄFÄ?F
ÅFÅ)F
ÆF
ÆF
ÆF
c                 óŠ   — | j                   j                  dd|› d�«      }t        | j                   |j                  «       «      S )ú²
        Cancel a prediction.

        Args:
            id: The ID of the prediction to cancel.
        Returns:
            Prediction: The canceled prediction object.
        rà   rµ   ú/cancelr¶   r·   s      rN   rƒ   zPredictions.cancelP  s@   € ð �|‰|×$Ñ$ØØ˜r˜d 'Ð*ó
ˆô
 # 4§<¡<°·±³Ó=Ð=rP   c              ƒ   ó¦   K  — | j                   j                  dd|› d�«      ƒ d{  –—† }t        | j                   |j                  «       «      S 7 Œ(­w)rô   rà   rµ   rõ   Nr¹   r·   s      rN   r‹   zPredictions.async_cancela  sN   è ø€ ð —\‘\×0Ñ0ØØ˜r˜d 'Ð*ó
÷ 
ˆô
 # 4§<¡<°·±³Ó=Ð=ð
ús   ‚$A¦A§)A).)rQ   rR   rS   rT   r   rZ   r   r"   r¯   r²   ry   r‘   r   rÀ   r   r   r   r   r   r   rÄ   r   rì   rƒ   r‹   r[   rP   rN   rŸ   rŸ   &  s:  „ ññ'˜5  j°$Ð!6Ñ7ð 'À$ÀzÑBRó 'ð8 03ñ'à�c˜: tÐ+Ñ,ð'ð 
ˆjÑ	ó'ð:>�cð >˜jó >ð> #ð >¨*ó >ôN ô Nð: ðà�w �|Ñ$ðð ˜˜S #˜X™Ñ'ðð Ð=Ñ>ð	ð
 
òó ðð ðð �S˜%  S ™/¨7Ð2Ñ3ðð ˜˜S #˜X™Ñ'ð	ð
 Ð=Ñ>ðð 
òó ðð ðð ˜#˜u S¨# X™°Ð<Ñ=ðð ˜˜S #˜X™Ñ'ð	ð
 Ð=Ñ>ðð 
òó ðð AEØ<@ØJNØ*.ò>>ð ˜˜c 5¨¨c¨¡?°GÐ;Ñ<Ñ=ð>>ð ˜% ¨¨iÐ 7Ñ8Ñ9ð	>>ð
 ˜U 3¨¨c°3¨h©¸Ð#EÑFÑGð>>ð ˜˜S #˜X™Ñ'ð>>ð Ð=Ñ>ð>>ð 
ó>>ð@ ðà�w �|Ñ$ðð ˜˜S #˜X™Ñ'ðð Ð=Ñ>ð	ð
 
òó ðð ðð �S˜%  S ™/¨7Ð2Ñ3ðð ˜˜S #˜X™Ñ'ð	ð
 Ð=Ñ>ðð 
òó ðð ðð ˜#˜u S¨# X™°Ð<Ñ=ðð ˜˜S #˜X™Ñ'ð	ð
 Ð=Ñ>ðð 
òó ðð AEØ<@ØJNØ*.ò?>ð ˜˜c 5¨¨c¨¡?°GÐ;Ñ<Ñ=ð?>ð ˜% ¨¨iÐ 7Ñ8Ñ9ð	?>ð
 ˜U 3¨¨c°3¨h©¸Ð#EÑFÑGð?>ð ˜˜S #˜X™Ñ'ð?>ð Ð=Ñ>ð?>ð 
ó?>ðB>˜ð > ó >ð"> Sð >¨Zô >rP   rŸ   c                   óN   — e Zd ZU eee      ed<   eeej                        ed<   y)ÚCreatePredictionRequestParamsrw   ÚtimeoutN)	rQ   rR   rS   r   r   r„   rV   ÚhttpxÚTimeoutr[   rP   rN   rø   rø   s  s%   … Ø˜ $™Ñ(Ó(Ø˜ %§-¡-Ñ0Ñ1Ô1rP   rø   rh   r;   c                 ó<   — t        | ¬«      }t        | ¬«      }||dœS )NrÞ   )rw   rù   )Ú_create_prediction_timeoutÚ_create_prediction_headers)rh   rù   rw   s      rN   ræ   ræ   x  s*   € ô )¨dÔ3€GÜ(¨dÔ3€Gð Øñð rP   rÞ   c                 ód   — | syt        | t        «      rdn| }t        j                  d|dz   ¬«      S )a  
    Returns an `httpx.Timeout` instances appropriate for the optional
    `Prefer: wait=x` header that can be provided with the request. This
    will ensure that we give the server enough time to respond with
    a partial prediction in the event that the request times out.
    Ng      N@g      @g      à?)Úread)rz   r�   rú   rû   )rh   Úread_timeouts     rN   rý   rý   „  s0   € ñ Øä% d¬DÔ1‘4°t€LÜ�=‰=˜ <°#Ñ#5Ô6Ð6rP   c                 ól   — i }| r/t        | t        «      rd|d<   |S t        | t        «      rd| › �|d<   |S )Nrh   ÚPreferzwait=)rz   r�   rH   )rh   rw   s     rN   rþ   rþ   •  sH   € ð €GáÜ�dœDÔ!Ø &ˆG�HÑð €Nô ˜œcÔ"Ø"'¨ v ˆG�HÑØ€NrP   r&   r-   r¼   r½   r¾   ro   c                 ó–   — i }|�||d<   | �!t        | t        «      r| j                  n| |d<   |�||d<   |�||d<   |�||d<   |�||d<   |S )Nr-   r&   r¼   r½   r¾   ro   )rz   r   r$   )r&   r-   r¼   r½   r¾   ro   Ú_kwargsré   s           rN   rå   rå   £  s{   € ð €DàÐØˆˆW‰àÐÜ(2°7¼GÔ(D˜'Ÿ*š*È'ˆˆY‰àÐØ!ˆˆY‰àÐ$Ø$5ˆÐ Ñ!àÐ(Ø(=ˆÐ$Ñ%àÐØˆˆX‰à€KrP   rÝ   r   r©   c                 ó*   — t        di |¤Ž}| |_        |S )Nr[   )r"   r#   )rÝ   r©   Ú
predictions      rN   rª   rª   Ã  s   € ÜÑ#˜dÑ#€JØ€JÔØÐrP   )NNNN)=rj   rW   rd   Údataclassesr   Útypingr   r   r   r   r   r	   r
   r   r   r   r   rú   Útyping_extensionsr   r   r   Úreplicate.exceptionsr   r   Úreplicate.filer   Úreplicate.helpersr   r   Úreplicate.paginationr   Úreplicate.resourcer   r   Úreplicate.streamr   Úreplicate.versionr   rš   r   ÚImportErrorÚreplicate.clientr   rä   r   rã   r   r    r"   rŸ   rø   rH   r�   ræ   rû   rý   rZ   rþ   rå   rª   r[   rP   rN   Ú<module>r     sØ  ðÛ Û 	Û Ý !÷÷ ÷ ñ ó ß <Ñ <ç ;Ý /ß <Ý %ß 2Ý (Ý %ðÝ'ñ Ý'Ý/Ý%Ý0ôy�ô yôxJ>�)ô J>ôZ
2 Iô 2ð
	Ø
�5˜˜d˜Ñ#Ñ
$ð	à"ó	ð +/ò7Ø�e˜C ˜IÑ&Ñ'ð7à
ˆ5�=‰=˜$ÐÑó7ð& (,òà
�5˜˜d˜Ñ#Ñ
$ðð 
ˆ#ˆsˆ(�^óð" "Ø'+Ø15Ø!ñØ�e˜G S˜LÑ)Ñ*ðà�D˜˜c˜‘NÑ#ðð �c‰]ðð   ‘}ð	ð
 $ D¨¡IÑ.ðð �T‰Nðð 
ˆ#ˆsˆ(�^óð@ ð °°S¸#°X±ð À:ô øðG ò Ýðús   Á,E Å	EÅE