j&5ddlmZmZmZmZmZmZmZmZm Z m Z ddl m Z m Z ddlmZmZddlmZddlmZddlmZddlmZmZddlmZ dd lmZer dd lm Z dd l!m"Z"Gd deZ#GddeZ$ d$d d d d ddeee%efdee e%ee%e%fdfdee%dee%deee%dee%eff dZ&de%de%fdZ'de e%ee%e%fdfde e%dfde%fdZ(d d!d"ee%efde#fd#Z)y #e$rdd lZYwxYw)%) TYPE_CHECKINGAnyDictListLiteralOptionalTuple TypedDictUnionoverload) NotRequiredUnpack)async_encode_json encode_json)ModelVersionIdentifier)Model)Page) NamespaceResource)Version)v1N)Client)FileEncodingStrategycTeZdZUdZej Zded<eed< eed< e ee fed< e eed< e ded < e e eefed < e eed < e eed < e eed < e eed< e eed< e eed< e e eefed< ddZddZddZddZy)Trainingz: A training made for a model hosted on Replicate. r_clientidmodelversion destination)starting processing succeededfailedcanceledstatusinputoutputlogserror created_at started_at completed_aturlsNc|jjj|j}|j j D]\}}t |||y)z, Cancel a running training. N)r trainingscancelrdictitemssetattrselfr%namevalues \/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/replicate/training.pyr1zTraining.cancelUsK <<))009#==?002KD% D$ &3cK|jjj|jd{}|j j D]\}}t |||y78w)z; Cancel a running training asynchronously. N)rr0 async_cancelrr2r3r4r5s r9r<zTraining.async_cancel^sX //<//1KD% D$ &2r:cK|jjj|jd{}|j j D]\}}t |||y78w)zC Load the training from the server asynchronously. N)rr0 async_getrr2r3r4r@s r9 async_reloadzTraining.async_reloadpsX  ..88AA"<<>//1KD% D$ &2Br=)returnN)__name__ __module__ __qualname____doc__pydantic PrivateAttrr__annotations__strr rrrrrr1r<rBrEr:r9rr!s-,,.GX. G( J^ 3<  ?#0 O PP% DcN ##$ SM% 3-# C=< ( (3-7 4S> ""''''r:rceZdZdZddeeddfdeefdZ ddeeddfdeefdZ dedefd Z dedefd Z Gd d e Z e dd edeeefdedeedeeedef dZe ddeeeeefdfd eeefdeeeefdeddef dZdddddeeeeeefdfd eeeefdeeeefdeddef dZdeeeeefdfd eeefdeeefdeddef dZdedefdZdedefdZy) Trainingsz8 Namespace for operations related to trainings. cursorellipsisNrFc| td|jjd|durdn|}|j}|dDcgc]}t |j|c}|d<t t di|Scc}w)# List your trainings. Parameters: cursor: The cursor to use for pagination. Use the value of `Page.next` or `Page.previous`. Returns: Page[Training]: A page of trainings. Raises: ValueError: If `cursor` is `None`. cursor cannot be NoneGET. /v1/trainingsresultsrO) ValueErrorr_requestjson_json_to_trainingrrr6rRrespobjresults r9listzTrainings.lists >45 5||$$ fm? iikBEi. BP dllF 3. IH~$$$  sA<cK| td|jjd|durdn|d{}|j}|dDcgc]}t |j|c}|d<t t di|S7Pcc}ww)rUNrVrW.rXrYrO)rZr_async_requestr\r]rrr^s r9 async_listzTrainings.async_lists >45 5\\00 fm?  iikBEi. BP dllF 3. IH~$$$  s!3B BB B.B B rc|jjdd|}t|j|jS) Get a training by ID. Args: id: The ID of the training. Returns: Training: The training object. rW/v1/trainings/rr[r]r\r6rr_s r9r?z Trainings.gets>||$$ RD !  !tyy{;;r:cK|jjdd|d{}t|j|jS7(w)rgrWrhNrrdr]r\rjs r9rDzTrainings.async_getsL\\00 RD !   !tyy{;;  s#AA)AceZdZUdZeeeeefdfed< eeed< eeed< ee eed< eded<y ) Trainings.CreateTrainingParamsz#Parameters for creating a training.rr webhookwebhook_completedwebhook_events_filterrfile_encoding_strategyN) rGrHrIrJr rNr rMr rrOr:r9CreateTrainingParamsrns_13c3h8994S!!F&s++O*49551 +,B CCKr:rsrr'r rorqc yNrO)r6rr'r rorqkwargss r9createzTrainings.createsr:rrparamsrnc yrurO)r6rrr'rxs r9rwzTrainings.createsr:)rrr'cd}|rt|dkDr|dndx}r t|}t|dkDr|dn|}t|dkDr|d|d<t|dkDr|d|d<t|dkDr|d|d <t|d kDr7|d |d <n.|r|r t||}n|t|tr t|}|s t d |j d d}|t||j|}t|fi|} |jjd|| } t|j| jS)zT Create a new training using the specified model version as a base. Nrr rorprqz8model and version or shorthand version must be specifiedrrclientrrPOSTr\) len#_create_training_url_from_shorthand+_create_training_url_from_model_and_version isinstancerNrZpoprr_create_training_bodyr[r]r\) r6rrr'argsrxurl shorthandrrbodyr_s r9rwzTrainings.createsa '*4y1}DG$>y>9)D"4y1}DG%E4y1}(,Q}%4y1}$(Gy!4y1}.21g*+4y1}26q'./ w=eWMC ]z'375g>CWX X!',Dd!K  ||'=E %U5f5||$$  %  !tyy{;;r:c>Kt||}|jdd}| t||j|d{}t |fi|}|jj d||d{}t |j|jS7Z7*w)a Create a new training using the specified model version as a base. Args: version: The ID of the base model version that you're using to train a new model version. input: The input to the training. destination: The desired model to push to in the format `{owner}/{model_name}`. This should be an existing model owned by the user or organization making the API request. webhook: The URL to send a POST request to when the training is completed. Defaults to None. webhook_completed: The URL to receive a POST request when the prediction is completed. webhook_events_filter: The events to send to the webhook. Defaults to None. Returns: The training object. rrNrrr)rrrrrrdr]r\) r6rrr'rxrrrrr_s r9 async_createzTrainings.async_create4s*:%I!',Dd!K  +||'=E %U5f5\\00  1   !tyy{;; s!? K '$Q(+a.)9: %D!Y$$5 !((= $% Kr:refcLtj|\}}}d|d|d|dS)N /v1/models/r /versions/ /trainings)rparse)rrr7 version_ids r9rrs44::3?E4 qj J GGr:rrrcJt|tr|j|j}}nPt|tr |d|d}}n5t|t rt j|\}}}n tdt|tr |j}n|}d|d|d|dS)Nrr{zWmodel must be a Model, a tuple of (owner, name), or a string in the format 'owner/name'rrrr) rrrr7rrNrrrZrr)rrrr7_rs r9rrs%kk5::t E5 !Ahat E3 /55e<tQ e  '7#ZZ  qj J GGr:rrr\ctdi|}||_|jrjt|jtrPd|jvrBt j |jd}|jd|j|_ |S)NrrrO) rrr(rr2rrrr7r )rr\trainingrs r9r]r]ss$HH  x -  ( # ) )(//)*D E"$((1RWWI6 Or:ru)*typingrrrrrrr r r r typing_extensionsr rreplicate.helpersrrreplicate.identifierrreplicate.modelrreplicate.paginationrreplicate.resourcerrreplicate.versionrrKr ImportErrorreplicate.clientrreplicate.filerrrQrNrrrr]rOr:r9rs   2<7!%2%''3V'xV'rB< B?!c] !  } ! $DI. ! #s(^!HHSHSH H eCHow. /H 3 > "H H. h d38n  M s C%% C10C1