_jEddlmZddlmZddlmZddlmZddlmZddl m Z m Z ddl m Z Gdd eeZeGd d ZeGd d ZeGddZeGddZeGddZeGddZeGddZeGddZeGddZeGddZeGddZd d d!d"ed#eed$eeefd zd%eeefd zd&e d zd'eezezd zd(eeefd zd)ee d zd*eeeffd+Zd S),) dataclass)datetime)Enum)Any) constants) SpaceHardwareVolume)parse_datetimec*eZdZdZdZdZdZdZdZdZ dS) JobStageav Enumeration of possible stage of a Job on the Hub. Value can be compared to a string: ```py assert JobStage.COMPLETED == "COMPLETED" ``` Possible values are: `COMPLETED`, `CANCELED`, `ERROR`, `DELETED`, `SCHEDULING`, `RUNNING`. Taken from https://github.com/huggingface/moon-landing/blob/main/server/job_types/JobInfo.ts#L61 (private url). COMPLETEDCANCELEDERRORDELETED SCHEDULINGRUNNINGN) __name__ __module__ __qualname____doc__r rrrrrV/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/huggingface_hub/_jobs_api.pyr r s8  IH EGJGGGrr c*eZdZUeed<edzed<dS) JobStatusstageNmessage)rrrr __annotations__strrrrrr-s+ OOO 4Zrrc.eZdZUeed<eed<eed<dS)JobOwneridnametypeN)rrrrrrrrr!r!3s+ GGG III IIIIIrr!cLeZdZUdZedzed<edzed<edzed<ddZdS) JobDurationsau Timing breakdown for a Job, computed server-side. Args: scheduling_secs (`int` or `None`): Seconds the job spent in the scheduling stage before starting to run. `None` if the job never reached the running stage. running_secs (`int` or `None`): Seconds the job has been or was running. Recomputed on each request while the job is in progress. `None` if the job never started running. total_secs (`int` or `None`): Total seconds elapsed since the job was created. Recomputed on each request while the job is in progress. Nscheduling_secs running_secs total_secsreturnc |d|d|_|d|d|_|d|d|_dS)NschedulingSecsr' runningSecsr( totalSecsr))getr'r(r)selfkwargss r__init__zJobDurations.__init__Osm%zz*:FJJGX>> from huggingface_hub import run_job >>> job = run_job( ... image="python:3.12", ... command=["python", "-c", "print('Hello from the cloud!')"] ... ) >>> job JobInfo(id='687fb701029421ae5549d998', created_at=datetime.datetime(2025, 7, 22, 16, 6, 25, 79000, tzinfo=datetime.timezone.utc), started_at=datetime.datetime(2025, 7, 22, 16, 6, 31, 79000, tzinfo=datetime.timezone.utc), finished_at=None, docker_image='python:3.12', space_id=None, command=['python', '-c', "print('Hello from the cloud!')"], arguments=[], environment={}, secrets={}, flavor='cpu-basic', labels=None, status=JobStatus(stage='RUNNING', message=None), durations=JobDurations(scheduling_secs=6, running_secs=2, total_secs=8), owner=JobOwner(id='5e9ecfc04957053f60648a3e', name='lhoestq', type='user'), initiator=JobInitiator(type='user', id='5e9ecfc04957053f60648a3e', name='lhoestq'), endpoint='https://huggingface.co', url='https://huggingface.co/jobs/lhoestq/687fb701029421ae5549d998') >>> job.id '687fb701029421ae5549d998' >>> job.url 'https://huggingface.co/jobs/lhoestq/687fb701029421ae5549d998' >>> job.status.stage 'RUNNING' ``` r"N created_at started_at finished_at docker_imagespace_idcommand arguments environmentsecretsflavorlabelsvolumesstatus durationsowner initiatorendpointurlr*c ~|d|_|dp|d}|rt|nd|_|dp|d}|rt|nd|_|dp|d}|rt|nd|_|dp|d |_|d p|d |_|d i}t|d|d |d|_ |d|_ |d|_ |d|_ |d|_ |d|_|d|_|d}|r d|Dnd|_|di}t#|d|d|_|d}|r t'd"i|nd|_|d} | r1t+| d| d| d nd|_|dt.j|_|jd |j jd!|j|_dS)#Nr" createdAtr: startedAtr; finishedAtr< dockerImager=spaceIdr>rHr#r$r"r#r$r?r@rArBrCrDrEc&g|]}tdi|Srr .0vs r z$JobInfo.__init__.."555  555rrFrr)rrrGrI)r$r"r#rJz/jobs//r)r"r/r r:r;r<r=r>r!rHr?r@rArBrCrDrErrFr&rGr7rIrENDPOINTrJr#rK) r1r2r:r;r<rHrErFrGrIs rr3zJobInfo.__init__s,ZZ ,,H <0H0H 8BL.444ZZ ,,H <0H0H 8BL.444jj..K&**]2K2K :EO>+6664"JJ}55SN9S9S 9--GJ1G1G  7B''t5=uV}UUU zz),, K00!::m44zz),, jj** jj** **Y''9@J55W5555d Hb))fWovzz)?T?TUUU JJ{++ 6?I22 222TJJ{++ dm wLi/IdO)--X^J_J_ ` ` ` `sw   :y/ABB mFF4:?FFTWFFrr4)rrrrrrrlistdictrrr rr&r!r7r3rrrr9r9es|<<| GGG44D   *Dj #Y Cy4c3h$&&&& #s(^d """" D    cNT !!!! &\D    d"""" OOOd""""MMM HHHGGGGGGrr9c8eZdZUedzed<edzed<eedzed<eedzed<eeefdzed<eeefdzed<edzed<e dzed <eedzed <edzed <eeefdzed <ee dzed <ddZ dS)JobSpecNr=r>r?r@rArBrCtimeouttagsarchrDrEr*c |dp|d|_|dp|d|_|d|_|d|_|d|_|d|_|d |_|d |_|d |_ |d |_ |d |_ |d}|r d|Dnd|_ dS)NrPr=rQr>r?r@rArBrCrarbrcrDrEc&g|]}tdi|SrTrUrVs rrYz$JobSpec.__init__..rZr) r/r=r>r?r@rArBrCrarbrcrDrE)r1r2rEs rr3zJobSpec.__init__s,"JJ}55SN9S9S 9--GJ1G1G zz),, K00!::m44zz),, jj** zz),, JJv&& JJv&& jj** **Y''9@J55W5555d rr4) rrrrrr]r^rrr5r r3rrrr`r`s *Dj #Y Cy4c3h$&&&& #s(^d """" D    4Z s)d  * cNT !!!! &\D     K K K K K Krr`c,eZdZUeed<eed<ddZdS) LastJobInfor"atr*Nc T|d|_t|d|_dS)Nr"rh)r"r rhr0s rr3zLastJobInfo.__init__s$, ..rr4)rrrrrrr3rrrrgrgs< GGGLLL//////rrgc8eZdZUedzed<edzed<ddZdS)ScheduledJobStatusNlast_jobnext_job_run_atr*c "|dp|d}|r tdi|nd|_|dp|d}|rtt |nd|_dS)NlastJobrl nextJobRunAtrmr)r/rgrlr rrm)r1r2rlrms rr3zScheduledJobStatus.__init__ s::i((BFJJz,B,B3;E //h///  **^44U CT8U8UGV`~c/.B.BCCC\`rr4)rrrrgrrr3rrrrkrksQD    _$$$aaaaaarrkceZdZUdZeed<edzed<eed<edzed<edzed<edzed<e ed <e ed <d d Z dS)ScheduledJobInfoa Contains information about a Job. Args: id (`str`): Scheduled Job ID. created_at (`datetime` or `None`): When the scheduled Job was created. tags (`list[str]` or `None`): The tags of the scheduled Job. schedule (`str` or `None`): One of "@annually", "@yearly", "@monthly", "@weekly", "@daily", "@hourly", or a CRON schedule expression (e.g., '0 9 * * 1' for 9 AM every Monday). suspend (`bool` or `None`): Whether the scheduled job is suspended (paused). concurrency (`bool` or `None`): Whether multiple instances of this Job can run concurrently. status (`ScheduledJobStatus` or `None`): Status of the scheduled Job. owner: (`JobOwner` or `None`): Owner of the scheduled Job, e.g. `JobOwner(id="5e9ecfc04957053f60648a3e", name="lhoestq", type="user")` job_spec: (`JobSpec` or `None`): Specifications of the Job. Example: ```python >>> from huggingface_hub import run_job >>> scheduled_job = create_scheduled_job( ... image="python:3.12", ... command=["python", "-c", "print('Hello from the cloud!')"], ... schedule="@hourly", ... ) >>> scheduled_job.id '687fb701029421ae5549d999' >>> scheduled_job.status.next_job_run_at datetime.datetime(2025, 7, 22, 17, 6, 25, 79000, tzinfo=datetime.timezone.utc) ``` r"Nr:job_specschedulesuspend concurrencyrFrHr*c *|d|_|dp|d}|rt|nd|_t di|dp|di|_|d|_|d|_|d|_|d i}t|d p|d |d p|d |_ |di}t|d|d|d|_ dS)Nr"rMr:rsjobSpecrtrurvrFrlrormrp)rlrmrHr#r$rRr) r"r/r r:r`rsrtrurvrkrFr!rH)r1r2r:rFrHs rr3zScheduledJobInfo.__init__Es\,ZZ ,,H <0H0H 8BL.444XX6::j#9#9#VVZZ SU=V=VXX  :.. zz),, !::m44Hb))(ZZ ++Dvzz)/D/D"JJ'899WVZZ=W=W     7B''t5=uV}UUU rr4) rrrrrrrr`boolrkr!r3rrrrrrrs&&P GGG4Dj D[  OOOVVVVVVrrrcNeZdZUdZeed<eed<eed<eed<eed<d d ZdS) JobAcceleratora Contains information about a Job accelerator (GPU). Args: type (`str`): Type of accelerator, e.g. `"gpu"`. model (`str`): Model of accelerator, e.g. `"T4"`, `"A10G"`, `"A100"`, `"L4"`, `"L40S"`. quantity (`str`): Number of accelerators, e.g. `"1"`, `"2"`, `"4"`, `"8"`. vram (`str`): Total VRAM, e.g. `"16 GB"`, `"24 GB"`. manufacturer (`str`): Manufacturer of the accelerator, e.g. `"Nvidia"`. r$modelquantityvram manufacturerr*Nc |d|_|d|_|d|_|d|_|d|_dS)Nr$r|r}r~r)r$r|r}r~rr0s rr3zJobAccelerator.__init__nsB6N G_ z* 6N ">2rr4)rrrrrrr3rrrr{r{Vsf III JJJMMM III333333rr{c|eZdZUdZeed<eed<eed<eed<eed<edzed<eed <eed <eed <dd Z dS) JobHardwarea  Contains information about available Job hardware. Args: name (`str`): Machine identifier, e.g. `"cpu-basic"`, `"a10g-large"`. pretty_name (`str`): Human-readable name, e.g. `"CPU Basic"`, `"Nvidia A10G - large"`. cpu (`str`): CPU specification, e.g. `"2 vCPU"`, `"12 vCPU"`. ram (`str`): RAM specification, e.g. `"16 GB"`, `"46 GB"`. ephemeral_storage (`str`): Ephemeral storage specification, e.g. `"20 GB"`, `"100 GB"`. accelerator (`JobAccelerator` or `None`): GPU/accelerator details if available. unit_cost_micro_usd (`int`): Cost in micro-dollars per unit, e.g. `167` (= $0.000167). unit_cost_usd (`float`): Cost in USD per unit, e.g. `0.000167`. unit_label (`str`): Cost unit period, e.g. `"minute"`. Example: ```python >>> from huggingface_hub import list_jobs_hardware >>> hardware_list = list_jobs_hardware() >>> hardware_list[0] JobHardware(name='cpu-basic', pretty_name='CPU Basic', cpu='2 vCPU', ram='16 GB', ephemeral_storage='20 GB', accelerator=None, unit_cost_micro_usd=167, unit_cost_usd=0.000167, unit_label='minute') >>> hardware_list[0].name 'cpu-basic' ``` r# pretty_namecpuramephemeral_storageN acceleratorunit_cost_micro_usd unit_cost_usd unit_labelr*c F|d|_|d|_|d|_|d|_|dd|_|d}|r t d i|nd|_|d|_|d |_ |d |_ dS) Nr# prettyNamerrephemeralStoragezN/ArunitCostMicroUSD unitCostUSD unitLabelr) r#rrrr/rr{rrrr)r1r2rs rr3zJobHardware.__init__s6N !,/%=%=!',>!F!Fjj// 88K888T#)*<#= #M2 -rr4) rrrrrrr{r5floatr3rrrrrvs!!F III HHH HHH$&&&&OOO . . . . . .rrN)rDrEimager?envrBrCrarDrEr*c|g|pi|p tjd}|r||d<|roddddd} t|trA|d| vr7t t |dd| |dz|d <nt ||d <|r||d <|rd |D|d <d D]3} || r|t| d|d<n4||d<|S)N)r?r@rArCrB<iiQ)smhdtimeoutSecondsrDc6g|]}|Sr)to_dict)rWvols rrYz$_create_job_spec..s @@@s{{}}@@@rrE)zhttps://huggingface.co/spaces/zhttps://hf.co/spaces/zhuggingface.co/spaces/z hf.co/spaces/rQrP)r CPU_BASIC isinstancerr5r startswithlen) rr?rrBrCrarDrErstime_units_factorsprefixs r_create_job_specrsPyb3M3   H&%6#$2DyII gs # # 6 7I(I(I),U73B3<-@-@CUV]^`VaCb-b)c)cH% & &),WH% & $#A@@@@@ ( (   F # # "'F "6HY  E #( Or) dataclassesrrenumrtypingrhuggingface_hubrhuggingface_hub._space_apirr huggingface_hub.utils._datetimer rr rr!r&r7r9r`rgrkrrr{rr]r^r5rrrrrrs"!!!!!%%%%%%<<<<<<<<::::::sD*       LLLLLLL L4           tGtGtGtGtGtGtG tGn KKKKKKK K< /////// / aaaaaaa a @V@V@V@V@V@V@V @VF 3333333 3> 8.8.8.8.8.8.8. 8.F%)#'... .#Y. c3h$  . #s(^d " . D .5[3  %. cNT !.&\D . #s(^......r