/jZj%ZddlZddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZGd d eeZGd d eeZej*ej,ej.ej0fZdZdZeGddZeGddZeGddZeGddZeGddZ eGddZ!eGddZ"eGddZ#eGd d!Z$eGd"d#Z%eGd$d%Z&eGd&d'Z'd(ee zd)efd*Z(d+ed)efd,Z)d-e*ed)efd.Z+dd/d0ed1e*ed2e*edzd)efd3Z,dd/d4ed5e*ed2e*edzd)efd6Z-d7e*e.dzd8e*e.dzd)e/ee*e.ffd9Z0dddddd:ddddd; d0ed1e*edeezdzd?e.e1zezdzd+edzd@e/eefdzdAe*edzd7e*e.dzd8e*e.dzdBe2dCedzdDe*edzdEedzdFe.dzd)e/ee ff"dGZ3y)HN) dataclass)datetime)Enum)Path)Any) constants)Volume)parse_datetimecxeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZy) JobHardwarea  Enumeration of hardware flavors available to run Jobs on the Hub. Value can be compared to a string: ```py assert JobHardware.CPU_BASIC == "cpu-basic" ``` Both enums are kept in sync with the Hub API by `utils/check_hardware_flavors.py`. z cpu-basicz cpu-upgradezcpu-performancezcpu-xlzt4-smallz t4-mediuml4x1l4x4l40sx1l40sx4l40sx8z a10g-smallz a10g-largez a10g-largex2z a10g-largex4z a100-largea100x4a100x8h200h200x2h200x4h200x8z rtx-pro-6000zrtx-pro-6000x2zrtx-pro-6000x4zrtx-pro-6000x8N)__name__ __module__ __qualname____doc__ CPU_BASIC CPU_UPGRADECPU_PERFORMANCECPU_XLT4_SMALL T4_MEDIUML4X1L4X4L40SX1L40SX4L40SX8 A10G_SMALL A10G_LARGE A10G_LARGEX2 A10G_LARGEX4 A100_LARGEA100X4A100X8H200H200X2H200X4H200X8 RTX_PRO_6000RTX_PRO_6000X2RTX_PRO_6000X4RTX_PRO_6000X8\/root/repos/pocs/video-evals/.venv/lib/python3.12/site-packages/huggingface_hub/_jobs_api.pyr r s IK'O FHI D D F F FJJ!L!LJ F F D F F F!L%N%N%Nr7r c(eZdZdZdZdZdZdZdZdZ y) 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) rrrrr;r<r=r>r?r@r6r7r8r:r:Gs' IH EGJGr7r:z(ghcr.io/astral-sh/uv:python3.12-bookworm)zhttps://huggingface.co/spaces/zhttps://hf.co/spaces/zhuggingface.co/spaces/z hf.co/spaces/cNeZdZUeed<edzed<eedzed<edzed<y) JobStatusstageNmessage expose_urlsssh_url)rrrr:__annotations__strlistr6r7r8rBrBks* O 4ZcT!! 4Zr7rBc,eZdZUeed<eed<eed<y)JobOwneridnametypeN)rrrrHrGr6r7r8rKrKss G I Ir7rKc4eZdZUdZeed<eeed<ddZy) JobNetworka Network group a Job joined. Args: group (`str`): Name of the network group, as passed to `network_group=`. aliases (`list[str]`): Aliases the Job claims in the group, as passed to `network_aliases=`. Empty when none. groupaliasesNc L|d|_|jdxsg|_y)NrQrR)rQgetrRselfkwargss r8__init__zJobNetwork.__init__s"G_ zz),2 r7returnN)rrrrrHrGrIrXr6r7r8rPrPzs J #Y3r7rPcJeZdZUdZedzed<edzed<edzed<ddZy) 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_secsc |jd|jd|_|jd|jd|_|jd|jd|_y)NschedulingSecsr] runningSecsr^ totalSecsr_)rTr]r^r_rUs r8rXzJobDurations.__init__sW%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' ``` rLN created_at started_at finished_at docker_imagespace_idcommand arguments environmentsecretsflavorlabelsvolumesstatus durationsowner initiatornetworkretryexpose expose_publicendpointurlc |d|_|jdxs|jd}|r t|nd|_|jdxs|jd}|r t|nd|_|jdxs|jd}|r t|nd|_|jdxs|jd |_|jd xs|jd |_|jd i}t|d|d |d|_ |jd|_ |jd|_ |jd|_ |jd|_ |jd|_|jd|_|jd}|r|Dcgc] }t!d(i|c}nd|_|jdi}t%|d|jd|jd|jd|_|jd} | r t)d(i| nd|_|jd} | r#t-| d| d| jd nd|_|jd } | r t1d(i| nd|_|jd!|_|jd"xsi} | jd#|_| jd$|_|jd%t:j<|_|j>d&|jj@d'|j|_!ycc}w))NrL createdAtri startedAtrj finishedAtrk dockerImagerlspaceIdrmrwrMrNrLrMrNrnrorprqrrrsrtrurCrD exposeUrlssshUrl)rCrDrErFrvrx)rNrLrMryrzr{ports portsPublicr}z/jobs//r6)"rLrTr rirjrkrlrmrKrwrnrorprqrrrsr rtrBrur\rvrfrxrPryrzr{r|rENDPOINTr}rMr~) rVrWrirjrkrwrtvrurvrxryr{s r8rXzJobInfo.__init__$s,ZZ ,H <0H 8B.4ZZ ,H <0H 8B.4jj.K&**]2K :E>+64"JJ}5SN9S 9-GJ1G  7B't5=uV}U zz), K0!::m4zz), jj* jj* **Y'9@W5  5d Hb)/JJy) <0JJx(   JJ{+ 6?2 2TJJ{+ dmLi/IdO)--X^J_ `sw **Y'07z,G,T ZZ( H%+jj) #ZZ 6 :y/A/AB mm_F4::??*;1TWWIF/6sM;rY)rrrrrHrGrrIdictrr r rBr\rKrfrPrdrXr6r7r8rhrhsM^ G44D *Dj #Y Cy4c3h$&& #s(^d "" $  cNT !! &\D  d"" Od"" $  : I 9t##M H*Gr7rhcHeZdZUedzed<edzed<eedzed<eedzed<eeefdzed<eeefdzed<edzed<e dzed <eedzed <edzed <eeefdzed <ee dzed <e dzed<ee dzed<ee dzed<ddZ y)JobSpecNrlrmrnrorprqrrtimeouttagsarchrsrtrzr{r|c R|jdxs|jd|_|jdxs|jd|_|jd|_|jd|_|jd|_|jd|_|jd |_|jd |_|jd |_ |jd |_ |jd |_ |jd}|r|Dcgc] }tdi|c}nd|_ |jd|_|jdxsi}|jd|_|jd|_ycc}w)Nrrlrrmrnrorprqrrrrrrsrtrzr{rrr6)rTrlrmrnrorprqrrrrrrsr rtrzr{r|)rVrWrtrr{s r8rXzJobSpec.__init__csC"JJ}5SN9S 9-GJ1G zz), K0!::m4zz), jj* zz), JJv& JJv& jj* **Y'9@W5  5d ZZ( H%+jj) #ZZ 6 6s0F$rY) rrrrHrGrIrrr rdr rXr6r7r8rrQs*Dj #Y Cy4c3h$&& #s(^d "" $  4Z s)d  * cNT !! &\D  : I 9t##7r7rc*eZdZUeed<eed<ddZy) LastJobInforLatNc >|d|_t|d|_y)NrLr)rLr rrUs r8rXzLastJobInfo.__init__|s, .r7rY)rrrrHrGrrXr6r7r8rrws GL/r7rc6eZdZUedzed<edzed<ddZy)ScheduledJobStatusNlast_jobnext_job_run_atc |jdxs|jd}|r tdi|nd|_|jdxs|jd}|rtt ||_yd|_y)NlastJobr nextJobRunAtrr6)rTrrr rHr)rVrWrrs r8rXzScheduledJobStatus.__init__sj::i(BFJJz,B3; /h/  **^4U CT8UGV~c/.BC\`r7rY)rrrrrGrrXr6r7r8rrsD  _$ar7rceZdZUdZeed<edzed<eed<edzed<edzed<edzed<e ed <e ed <d d Z y) 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) ``` rLNrijob_specschedulesuspend concurrencyrurwc |d|_|jdxs|jd}|r t|nd|_t di|jdxs|jdi|_|jd|_|jd|_|jd|_|jd i}t|jd xs|jd |jd xs|jd |_ |jdi}t|d|d|d|_ y)NrLrrirjobSpecrrrrurrrr)rrrwrMrNrr6) rLrTr rirrrrrrrurKrw)rVrWrirurws r8rXzScheduledJobInfo.__init__s,ZZ ,H <0H 8B.4X6::j#9#VVZZ SU=VX  :. zz), !::m4Hb)(ZZ +Dvzz)/D"JJ'89WVZZ=W   7B't5=uV}U r7rY) rrrrrHrGrrboolrrKrXr6r7r8rrsN&P G4Dj D[  OVr7rcLeZdZUdZeed<eed<eed<eed<eed<d dZy) 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"`. rNmodelquantityvram manufacturerNc h|d|_|d|_|d|_|d|_|d|_y)NrNrrrr)rNrrrrrUs r8rXzJobAccelerator.__init__s<6N G_ z* 6N ">2r7rY)rrrrrHrGrXr6r7r8rrs( I JM I3r7rczeZdZUdZeed<eed<eed<eed<eed<edzed<eed <eed <eed <d d Z y)JobHardwareInfoa$ 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] JobHardwareInfo(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' ``` rM pretty_namecpuramephemeral_storageN acceleratorunit_cost_micro_usd unit_cost_usd unit_labelc |d|_|d|_|d|_|d|_|j dd|_|j d}|r t d i|nd|_|d|_|d |_ |d |_ y) NrM prettyNamerrephemeralStoragezN/ArunitCostMicroUSD unitCostUSD unitLabelr6) rMrrrrTrrrrrr)rVrWrs r8rXzJobHardwareInfo.__init__ s6N !,/%=%=!',>!Fjj/ 8K8T#)*<#= #M2 -r7rY) rrrrrHrGrrdfloatrXr6r7r8rrsF!F I H H$&&O .r7rsourcerZc4t|jj}tjt j d|jjdd}|jjddxsd}|d|S)aDerive a stable remote folder name for a local directory synced as a Job volume. The name is `{dirname}-{hash}` where the hash fingerprints the absolute path and the machine's hostname: re-syncing the same directory from the same machine reuses the same remote folder (so only changed files are re-uploaded), while same-named directories from different paths or machines don't collide. :N _root-) r expanduserresolvehashlibsha256platformnodeencode hexdigestrMreplace)rresolveddigestdirnames r8_derive_job_volume_namer-sF|&&(002H ^^x}}/q ;BBD E O O QRTST UFmm##C-7GYax  r7rMc0tjdd|S)zSanitize a string so it is a valid Job `name` label. Job names must match `^[a-zA-Z0-9._-]*$` and are also stored as tags, which only allow alphanumerics, `-` and `_`. Every other character (including `/`, `:` and `.`) is replaced with `-`. z[^a-zA-Z0-9_-]r)resub)rMs r8_sanitize_job_namer;s 66#S$ //r7partsctjdj|jj ddS)zShort, stable hash of a Job invocation (image/script + command line). Appended to auto-generated names so reruns of the same command share a name while different ones don't. Nr)rrjoinrr)rs r8_short_invocation_hashrDs5 >>&++e,335 6 @ @ B2A FFr7) config_partsimagernrctD]0}|j|st|t|dxs|}n1t|j dj ddxs|}|dt |g||xsgS)aQDerive a default Job name from a Docker image or Space reference and its command. A short hash of the full command line is appended to group reruns of the same command. e.g. python:3.12 + [foo, --truc] -> python-3-12-1a2b3c4d hf.co/spaces/lhoestq/duckdb -> lhoestq-duckdb- pytorch/pytorch:2.6.0-cuda12.4-... -> pytorch-2-6-0-cuda12-4-...- `config_parts` adds the rest of the resolved launch configuration (flavor, env, ...) to the hash. The CLI passes it so that the name reflects the values actually submitted. Nrr)_SPACE_IMAGE_PREFIXES startswithrlenrstripsplitr)rrnrprefixbases r8_default_job_name_from_imagerLs(M   F #%eCKM&:&CeDD M "%,,s"3"9"9#">r"B"KeLV1+U,TW,T @RPR,TUV WWr7script script_argsc$|jdddjdddjdjdd}|jdr|dtd }t |xs|}|d t |g||xsgS) aDerive a default Job name from a UV script path, URL, or command and its arguments. A short hash of the full command line is appended to group reruns of the same command. e.g. my_script.py + [--epochs, 3] -> my_script-1a2b3c4d https://.../sft.py?raw=1 -> sft- lighteval -> lighteval- `config_parts` adds the rest of the resolved launch configuration (image, flavor, env, ...) to the hash. The CLI passes it so that the name reflects the values actually submitted, including those coming from a script's `[tool.hf-jobs]` header rather than from the command line. ?r#rrz.pyNr)rrendswithrrr)rrrrMrs r8_default_job_name_from_scriptr`s <<Q  " ( (a 0 3 : :3 ? E Ec J2 ND }}UMs5zk" dnf -DV1+V,Yk,Y\EWUW,YZ[ \\r7r{r|cttj|xsg}ttjg|xsg||dS)N)rr)rIrfromkeys)r{r| ports_publics r8_build_expose_payloadrusC m&9r:;L$--(H6`name` and the `name` key in `labels` cannot both be provided.)rnrorprrrqr<iiQ)smhdrtimeoutSecondsrrsrtr{enabledTrrQrRryresourceGroupIdrr) ValueErrorr r isinstancerHrdrto_dictrrrr)rrnrrqrrrrMrsrtr{r|rrrrrrtime_units_factorsvolryrs r8_create_job_specr {s&}FGG   &F"2]^ ^1V\r1FD1yb1K11  H%#$2DyI gs # 7I(I),U73B<-@CUV]^`VaCb-b)cH% &),WH% &' #8?@s{{}@ 26=I $d+#*M": !0GI %&7"#'(   F #"'F "6HY   O ( #( O/As9E)4rrr dataclassesrrenumrpathlibrtypingrhuggingface_hubrhuggingface_hub._space_apir huggingface_hub.utils._datetimer rHr r:r;r<r=r>TERMINAL_JOB_STAGESDEFAULT_UV_IMAGErrBrKrPr\rfrhrrrrrrrrrIrrrrdrrrrr r6r7r8rs  !%-:(&#t(&VsD, ))8+<+      33 3& LL L4      TGTG TGn "7"7 "7J // / aa a @V@V @VF 33 3> 8.8. 8.v !C$J !3 !0S0S0G$s)GGfjXXd3iXRVWZR[^bRbXnqX*NR] ]"3i]:>s)d:J]]*i$s)d"2i49tCSiX\]`bfgjbk]kXli$(#'#&* $(,$(#I I#YI c3h$  I #s(^d " I #  $ I5[3  %I *I cNT !I&\D I I I9t#I I:I#Y%I Tz!I"Dj#I$ #s(^%Ir7