}tj\:ddlZddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZGd d eeZGd d eeZejejejejfZdZeGddZeGddZeGddZeGddZeGddZeGddZ eGddZ!eGddZ"eGdd Z#eGd!d"Z$eGd#d$Z%d%ee zd&efd'Z&d(ed&efd)Z'd*e(ed&efd+Z)d,ed-e(ed&efd.Z*d/ed0e(ed&efd1Z+ddddd2dd3d,ed-e(ed4e,ee fdzd5e,ee fdzd6eezdzd7e-e.zezdzd(edzd8e,eefdzd9e(edzd:e(e-dzd;e/dN) dataclass)datetime)Enum)Path)Any) constantsVolume)parse_datetimeczeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdS) 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_6000X8W/var/www/html/CA-Chatbot/venv/lib/python3.11/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%NNNr8r c*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) rrrrr<r=r>r?r@rAr7r8r9r;r;Gs8  IH EGJGGGr8r;)zhttps://huggingface.co/spaces/zhttps://hf.co/spaces/zhuggingface.co/spaces/z hf.co/spaces/cVeZdZUeed<edzed<eedzed<edzed<dS) JobStatusstageNmessage expose_urlsssh_url)rrrr;__annotations__strlistr7r8r9rCrChsP OOO 4ZcT!!!! 4Zr8rCc.eZdZUeed<eed<eed<dS)JobOwneridnametypeN)rrrrIrHr7r8r9rLrLps+ GGG III IIIIIr8rLcLeZdZUdZedzed<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)NschedulingSecsrR runningSecsrS totalSecsrT)getrRrSrTselfkwargss r9__init__zJobDurations.__init__sm%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' ``` rMN created_at started_at finished_at docker_imagespace_idcommand arguments environmentsecretsflavorlabelsvolumesstatus durationsowner initiatorendpointurlrUc |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|d|_|d}|r t'd$i|nd|_|d} | r1t+| d| d| d  nd|_|d!t.j|_|jd"|j jd#|j|_dS)%NrM createdAtre startedAtrf finishedAtrg dockerImagerhspaceIdrirsrNrOrMrNrOrjrkrlrmrnrorpc&g|]}tdi|Sr7r .0vs r9 z$JobInfo.__init__.."555  555r8rqrDrE exposeUrlssshUrl)rDrErFrGrrrt)rOrMrNruz/jobs//r7)rMrZr rerfrgrhrirLrsrjrkrlrmrnrorprCrqrQrrrbrtrENDPOINTrurNrv) r\r]rerfrgrsrprqrrrts r9r^zJobInfo.__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))/JJy)) <00JJx((     JJ{++ 6?I22 222TJJ{++ dm wLi/IdO)--X^J_J_ ` ` ` `sw   :y/ABB mFF4:?FFTWFFr8r_)rrrrrIrHrrJdictrr r rCrQrLrbr^r7r8r9rdrds~DDL GGG44D   *Dj #Y Cy4c3h$&&&& #s(^d """" $  cNT !!!! &\D    d"""" OOOd""""MMM HHH$G$G$G$G$G$Gr8rdc8eZdZUedzed<edzed<eedzed<eedzed<eeefdzed<eeefdzed<edzed<e dzed <eedzed <edzed <eeefdzed <ee dzed <ddZ dS)JobSpecNrhrirjrkrlrmrntimeouttagsarchrorprUc |dp|d|_|dp|d|_|d|_|d|_|d|_|d|_|d |_|d |_|d |_ |d |_ |d |_ |d}|r d|Dnd|_ dS)Nr{rhr|rirjrkrlrmrnrrrrorpc&g|]}tdi|Srr rs r9rz$JobSpec.__init__..Crr8) rZrhrirjrkrlrmrnrrrrorp)r\r]rps r9r^zJobSpec.__init__6s,"JJ}55SN9S9S 9--GJ1G1G zz),, K00!::m44zz),, jj** zz),, JJv&& JJv&& jj** **Y''9@J55W5555d r8r_) rrrrIrHrJrrr r`r r^r7r8r9rr's *Dj #Y Cy4c3h$&&&& #s(^d """" $  4Z s)d  * cNT !!!! &\D     K K K K K Kr8rc,eZdZUeed<eed<ddZdS) LastJobInforMatrUNc T|d|_t|d|_dS)NrMr)rMr rr[s r9r^zLastJobInfo.__init__Ks$, ..r8r_)rrrrIrHrr^r7r8r9rrFs< GGGLLL//////r8rc8eZdZUedzed<edzed<ddZdS)ScheduledJobStatusNlast_jobnext_job_run_atrUc "|dp|d}|r tdi|nd|_|dp|d}|rtt |nd|_dS)NlastJobr nextJobRunAtrr7)rZrrr rIr)r\r]rrs r9r^zScheduledJobStatus.__init__Us::i((BFJJz,B,B3;E //h///  **^44U CT8U8UGV`~c/.B.BCCC\`r8r_)rrrrrHrr^r7r8r9rrPsQD    _$$$aaaaaar8rceZdZUdZeed<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) ``` rMNrejob_specschedulesuspend concurrencyrqrsrUc *|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)NrMrxrerjobSpecrrrrqrrrr)rrrsrNrOr}r7) rMrZr rerrrrrrrqrLrs)r\r]rerqrss r9r^zScheduledJobInfo.__init__s\,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 r8r_) rrrrrIrHrrboolrrLr^r7r8r9rr\s&&P GGG4Dj D[  OOOVVVVVVr8rcNeZdZUdZeed<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"`. rOmodelquantityvram manufacturerrUNc |d|_|d|_|d|_|d|_|d|_dS)NrOrrrr)rOrrrrr[s r9r^zJobAccelerator.__init__sB6N G_ z* 6N ">2r8r_)rrrrrIrHr^r7r8r9rrsf III JJJMMM III333333r8rc|eZdZUdZeed<eed<eed<eed<eed<edzed<eed <eed <eed <dd Z dS)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' ``` rN pretty_namecpuramephemeral_storageN acceleratorunit_cost_micro_usd unit_cost_usd unit_labelrUc F|d|_|d|_|d|_|d|_|dd|_|d}|r t d i|nd|_|d|_|d |_ |d |_ dS) NrN prettyNamerrephemeralStoragezN/ArunitCostMicroUSD unitCostUSD unitLabelr7) rNrrrrZrrrrrr)r\r]rs r9r^zJobHardwareInfo.__init__s6N !,/%=%=!',>!F!Fjj// 88K888T#)*<#= #M2 -r8r_) rrrrrIrHrr`floatr^r7r8r9rrs!!F III HHH HHH$&&&&OOO . . . . . .r8rsourcerUc\t|}tjt jd|dd}|j ddpd}|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 hexdigestrNreplace)rresolveddigestdirnames r9_derive_job_volume_namersF||&&((0022H ^x};;;;BBDD E E O O Q QRTSTRT UFm##C--7G   r8rNc.tjdd|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)rNs r9_sanitize_job_namer s 6#S$ / //r8partsctjd|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 r9_short_invocation_hashrsA >&++e,,3355 6 6 @ @ B B2A2 FFr8imagerjc8tD]?}||r(t|t|dp|}n>@t|dddp|}|dt |g|S)aDerive 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-...- Nrr)_SPACE_IMAGE_PREFIXES startswithrlenrstripsplitr)rrjprefixbases r9_default_job_name_from_imagers(MM   F # # %eCKKMM&:&CeDDD E "%,,s"3"3"9"9#">">r"B"KeLL @ @+U,=W,=>> @ @@r8script script_argscp|ddddddddd}|dr|dtd }t |p|}|d t |g|S) aaDerive 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- ?r#rrz.pyNr)rrendswithrrr)rrrNrs r9_default_job_name_from_scriptr,s <<Q   " ( (a 0 0 3 : :3 ? ? E Ec J J2 ND }}U#Ms5zzkM" dnf - -D E E+V,Bk,BCC E EEr8F)rNrorpexposesshresource_group_idenvrmrnrrorprrrc D||d|vrtdi|pid|i}|g|pi|p tjd} |r|| d<|roddddd } t|trA|d | vr7t t |dd | |d z| d <nt || d <|r|| d <|rd |D| d<| rd| i| d<| rddi| d<| r| | d<tD]3}||r|t|d| d<n4|| d<| S)NrNz>`name` and the `name` key in `labels` cannot both be provided.)rjrkrlrnrmr<iiQ)smhdrtimeoutSecondsroc6g|]}|Sr7)to_dict)rvols r9rz$_create_job_spec..es @@@s{{}}@@@r8rpportsrenabledTrresourceGroupIdr|r{) ValueErrorr r isinstancerIr`rrrr)rrjrrmrnrrNrorprrrrtime_units_factorsrs r9_create_job_specr;s   &F"2"2]^^ ^1V\r1FD11yb1K1   H&%6#$2DyII gs # # 6 7I(I(I),U73B3<-@-@CUV]^`VaCb-b)c)cH% & &),WH% & $#A@@@@@ /%v. ,$d+8&7"#'((   F # # "'F "6HY  E #( Or8)1rrr dataclassesrrenumrpathlibrtypingrhuggingface_hubrhuggingface_hub._space_apir huggingface_hub.utils._datetimer rIr r;r<r=r>r?TERMINAL_JOB_STAGESrrCrLrQrbrdrrrrrrrrrJrrrrr`rrrr7r8r9r s !!!!!!%%%%%%------::::::(&(&(&(&(&#t(&(&(&VsD, )8+ 8.8.8.8.8.8.8. 8.v !C$J !3 ! ! ! !0S0S0000G$s)GGGGGAAd3iACAAAA" F# FDI F# F F F F.$(#'#$(;;; ;#Y; c3h$  ; #s(^d " ; #  $ ;5[3  %; *; cNT !;&\D ; I ; ;Tz; #s(^;;;;;;r8