5pjt.SrSSKrSSKrSSKrSSKrSSKrSSKJrJr SSK J r SSK J r SSK J r Jr SSKJrJrJr SSKJr SS KJrJrJrJrJrJr SS KJr SS KJr SS K J!r! SS K"J#r# SSK$J%r% SSK&J'r'J(r( SSK)J*r*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5J6r6 SSK7J8r8J9r9 SSK:J;r;J5r?S\@S\@S-S\A\@\@S-44SjrBS\C\@S-S\S\@S-S\C\S-4SjrDSrE\\@\8"SS94rF\\@S-\9"SS94rG\\@S-\9"S\."\5S 94rH\\C\@S-\9"S!S"S#S94rI\\@S-\9"S$S%S94rJ\\@S-\9"S&S94rK\\L\9"S'S(S)S94rM\\@S-\9"S*S94rN\\@S-\9"S+S,S94rO\\C\PS-\9"S-S.S94rQ\\L\9"S/S0S94rR\\C\@S-\9"S1S2S94rS\\@S-\9"S3S4S5S94rT\\LS-\9"S6S94rU\\LS-\9"S7S94rV\\@\8"S8S94rW\\@\8"S9S94rX\\C\@S-\8"S:S94rY\\C\@\8"S;S94rZ\\@\8"SS94r]\\C\@S-\9"S?S@SAS94r^\6"SBS9r_S\SC\SS4SDjr`\_RSESFSG0/SHQSI9SSJ\FSK\ZSL\+SM\-SN\JSO\ISP\^SQ\*SR\,SS\HST\KSU\MSV\QSW\RSX\OS\NSY\1SS4$SZjj5rb\_RS[/S\QS]9SS\[S^\\L\9"S_S`SaS94Sb\\PS-\9"ScSdSeS94S\NSY\1SS4 Sfjj5rcSg\d\@\@4Sh\C\A\@\@\@4S\L4SijreSj\PSS4SkjrfS\@Sl\\d\@\4Sm\C\@S\\A\L\@\C\C\@\P-44Snjrg\_RSoSp/S]9SSq\\S\NSY\1SS4Srjj5rh\_RSs/StQS]9SSu\\L\9"SvSwSxS94Sy\\C\@S-\9"Sz\."\5S{S|94SO\\C\@S-\9"S!S"S}S94SN\\@S-\9"S$S~S94S\\P\9"SSS94S\NSY\1S\\C\@S-\9"S_SSS94SS4Sjj5ri\_RSS/S]9SSj5rj\_RSS/S]9SSq\\C\@\8"SS94S\NSY\1SS4Sjj5rk\_RSS/S]9SS\[S\NSY\1SS4Sjj5rl\_RS/SQS]9SSq\\C\@\8"SS94ST\\@S-\9"SS94S\NSY\1SS4 Sjj5rm\_RS/SQS]9SS\[SN\JSO\IS\\L\9"SSS94S\NSY\1SS4Sjj5rn\_RSW/SQS]9SS\[S\0S\/S\NSY\1SS4 Sjj5ro\6"SS9rp\_R\pSS9 \pRSESFSG0/SQSI9SS\XS\YSJ\GSS\HSL\+SM\-SN\JSO\ISP\^SQ\*SR\,ST\KSU\MSV\QSW\RSX\OS\NSY\1S\SS\TSS4*Sjj5rr\6"SS9rs\_R\sSS9 \sRSESFSG0S/SI9SS\WSJ\FSK\ZS\US\VSL\+SM\-SN\JSO\ISP\^SQ\*SR\,SS\HST\KSV\QSX\OS\NSY\1SS4&Sjj5rt\sRSsS/S]9SSu\\L\9"SvSwSS94S\NSY\1S\\C\@S-\9"S_SSS94SS4 Sjj5ru\sRSS/S]9SS\\C\@\8"SS94S\NSY\1SS4Sjj5rv\sRSS/S]9SS\]S\NSY\1SS4Sjj5rw\sRSS/S]9SS\]S\NSY\1SS4Sjj5rx\sRSS/S]9SS\]S\NSY\1SS4Sjj5ry\sRSS/S]9SS\]S\NSY\1SS4Sjj5rz\sRS/SQS]9SS\]SN\JSO\IS\\L\9"SSS94S\NSY\1SS4Sjj5r{\6"SS9r|\sR\|SS9 \|RSESFSG0SS/SI9SS\WS\XS\YS\US\VSJ\GSS\HSL\+SM\-SN\JSO\ISP\^SQ\*SR\,ST\KSV\QSX\OS\NSY\1S\SS\TSS4,Sjj5r}S\d\@\4S\d\@\@4S-S\d\@\44Sjr~SN\@S-SO\C\@S-S\L4SjrSS.S\C\@S-SN\@S-S\d\@\@4S-4SjjrS\C\C\@\P-S\C\@S\@4Sjr\"S5rS\\S\S\\4S\dSS4SjrS\GRGR S\S\\4S\C\dS\\4Sjrg)z@Contains commands to interact with jobs on the Hugging Face Hub.N)CallableIterable)fnmatch)Path)EmptyQueue) AnnotatedAnyTypeVar)urlsplit)HfApi JobHardwareJobInfoJobStageVolume constants)TERMINAL_JOB_STAGES)CLIError)logging) _format_size) _split_mount)format_durationparse_duration) EnvFileOptEnvOptSecretsFileOpt SecretsOpt SoftChoice SshDryRunOptSshIdentityFileOptTokenOptexec_ssh get_hf_api parse_env_map parse_volumes typer_factory)ArgumentOption)_dataclass_to_dictoutjob_id namespacereturncU(d [S5eURS5S:a[SUS35eSU;aX4$URSS5up#U(aU(d[SUS35eUbX:wa[SUSUS35eX24$) aExtract namespace from job_id if provided in 'namespace/job_id' format. Allows users to pass job IDs copied from the Hub UI (e.g. 'username/job_id') instead of only bare job IDs. If the namespace is also provided explicitly via --namespace and conflicts, a CLIError is raised. zJob ID cannot be empty./rz`. Requires an SSH public key registered on https://huggingface.co/settings/keys.z--withz%Run with the given packages installedz-pz--pythonz5The Python interpreter to use for the run environmentz!Suspend (pause) the scheduled Jobz8Allow multiple instances of this Job to run concurrentlyzWOne of annually, yearly, monthly, weekly, daily, hourly, or a CRON schedule expression.z$UV script to run (local file or URL)zArguments for the scriptzThe command to run.zJob ID (or 'namespace/job_id')zJob IDs (or 'namespace/job_id')z2Scheduled Job ID (or 'namespace/scheduled_job_id')z-vz--volumeaMount one or more volumes. Format: hf://[TYPE/]SOURCE:/MOUNT_PATH[:ro|:rw] or LOCAL_DIR:/MOUNT_PATH[:ro|:rw]. TYPE is one of: models, datasets, spaces, buckets. TYPE defaults to models if omitted. models, datasets and spaces are always mounted read-only. buckets are read+write by default. A local directory source is first synced to a bucket and mounted read-only by default. E.g. -v hf://datasets/org/ds:/data or -v hf://buckets/org/b:/mnt:ro or -v ./inputs:/inputszRun and manage Jobs on the Hub.jobc`URURURRSS9Hn[R "U5 M UR URURRS9nURR[R:wahURR(aSURR3OSn[SURSURRSU35e[R "SURS 35 g ) zcStream Job logs until the Job ends, then fail the command if the Job did not complete successfully.T)r,r-followr,r-z: zJob z finished with stage 'r1z completedN) fetch_job_logsidownernamer+text wait_for_jobstatusstager COMPLETEDmessager)r:rPlogfinalr^s r6_stream_logs_and_check_statusra>s!!399>>RV!W  X   CFFciinn  EE ||X///161E1EBu||++,-2ehhZ'=ell>P>P=QQRSZR[\]]HHtEHH:Z ()r8runignore_unknown_optionsT)zFhf jobs run --name hello-world python:3.12 python -c 'print("Hello!")'z1hf jobs run --detach python:3.12 python script.pyz3hf jobs run -e FOO=foo python:3.12 python script.pyz;hf jobs run --secrets HF_TOKEN python:3.12 python script.pyz^hf jobs run -v hf://org/my-model:/data -v hf://buckets/org/b:/mnt python:3.12 python script.py)context_settingsexamplesimagecommandenvsecretsrXlabelrLenv_file secrets_fileflavortimeoutdetachexposesshresource_group_idtokenc[X'5n[X85n[US9nURUUUU[XTS9[ UUUS9U U U U UUS9 n[ R "SURUR=(d 0RS5URS9 [XE5(dbUR=(d 0RS5n[ R"SUS URRS URS 35 [UR R"[$5(aES R'S UR R"55n[ R"SU35 [UR R([*5(a;[ R"SURRS URS35 U (a]URRS UR3n[ R"SUSUS35 [ R"SUS35 g[-UU5 g)z Run a Job.rsrXr:r-) rfrgrhrilabelsr9rmrnrprqrrr- Job startedrXrVrXurlJob auto-named '('. Pass `--name` or run `hf jobs labels r0 --name NAME` to rename it. c3,# UH nSU3v M g7fz N.0r{s r6 jobs_run..F/E2cU/ESExposed ports are reachable at (requires an HF token with read access to the job): Use `hf jobs ssh &` to open an SSH session into the job.Use `hf jobs logs -f &` to stream logs, or `hf jobs inspect ` to check status.Use `hf jobs wait ` to block until it finishes.N)r%r$run_job_parse_labels_maprMr+rIrVrxgetr{_has_explicit_namerErWrX isinstancer[ expose_urlslistjoinssh_urlstrra)rfrgrhrirXrjrLrkrlrmrnrorprqrrr-rsenv_map secrets_mapr:rP auto_nameurlsjob_refs r6jobs_runrJs>C*G6K 5 !C ++  2+FyQ +  CJJ}szz/?R.D.DV.LRURYRYZ d * *ZZ%2**62  yk*"yy~~.ax7R T #**(($//yyFszz/E/EFF ghlgmno#**$$c** $SYY^^$4AcffX=cde YY^^$AcffX. ( 1WX_W``rst %gY.KLM!#s+r8logs)zhf jobs logs zhf jobs logs -f zhf jobs logs --tail 20 z#hf jobs logs -f --tail 100 )rerRz-fz--followzqFollow log output (stream until the job completes). Without this flag, only currently available logs are printed.tailz-nz--tailzvNumber of lines to show from the end of the logs. When combined with --follow, starts streaming from the last N lines.c[X5up[US9nURXXS9nUHn[R"U5 M U(a+U(aUSU3OUn[R "SUS35 gg)aFetch the logs of a Job. By default, prints currently available logs and exits (non-blocking). Use --follow/-f to stream logs in real-time until the job completes. Use --tail/-n to limit the number of lines returned (server-side when supported). Note: following exits when the log stream ends, regardless of whether the Job succeeded or failed. Run `hf jobs inspect ` to check the final status. ru)r,r-rRrr0z#Stream ended. Run `hf jobs inspect z6` to check the final status (e.g. COMPLETED or ERROR).N)r7r$rUr+rYrE) r,rRrr-rsr:rr_rs r6 jobs_logsrsyN5VGF 5 !C   V  [D   -6YKq)F 6wi?uvwr8job_propertiesfilterscUHjup#nURU5nUc US:XaM" g[UR5UR55nUS:XaU(aUS:XdMaU(dMj g g)z5Check if scheduled job matches all specified filters.!=F=T)rrlower)rrkeyop_strpatternvaluematchs r6_matches_filtersrsf 'W""3' =~ w}}7 cM%Vt^!( r8ncBSnSn[U5H n[XS9 M g)Nzz)end)rangeprint)rLINE_UP LINE_CLEARis r6 _clear_liners"GJ 1X g&r8metrics_stream table_headersc ## UGHknUUSS3[USS- S5[SUS-US- S 5S3[US5S [US5S 3[US 5S [US5S3/nUS(a[US[5(aU/[ [ US5S- 5Vs/sHnS/[ U5-PM sn-n[ U[US55HRupGUSUnUUSS3[SUS-US- S 5S3[US5S [US5S 3/- nMT O!US/[ U5[ U5- -- nU/nSX4v GMn SU/4v gs snf7f)N cpu_usage_pct%cpu_millicoresg@@rdmemory_used_bytesmemory_total_byteszB / Brx_bpszbps / tx_bpsbpsgpusrT utilizationN/AFT)roundrrdictrlenzipsorted) r,rrmetricsrow_rowsgpu_idgpus r6_get_jobs_stats_rowsrs" '( * '*+f4a 8S7#677'BV:WWYZ[\\] ^G$789:$|GThLi?j>kkl mGH-./vl78CT6U5VVY Z   6?z'&/4@@5U3wv;ORS;S5TU5TRD3s8O5TUUD"4)@A fof-=)*!,S3':#;;cBV>WWYZ[\\]^#C(;$<=>djob_idsc Ub+/nUH!n[XA5upAURU5 M# Un[US9nUcUR5SnUcXUR US9Vs/sH>nUR (aUR R OSS;dM2URPM@ nn[U5S:Xa[R"S5 g/S Qn[RR[U55n0n UH1nU/n XS SV s/sHn S U ;dS U ;aS OSPM sn - n U /X'M3 [R"5n U VV s/sHoIUHoPM M n nn [[!XS95 UVs/sHnUUR#XAS9US.PM nn[%U[&US9HupnU(aU R)US5 OUX'[R"5nUU - [*:dMH[-S[U 5-5 U VV s/sHoIUHoPM M n nn [[!XS95 Un M SSS5 gs snfs sn fs sn nfs snfs sn nf!,(df  g=f)z7Fetch the resource usage statistics and metrics of JobsNrurXr-UNKNOWN)RUNNINGUPDATINGrzNo running jobs found) zJOB IDzCPU %zNUM CPUzMEM %z MEM USAGEzNET I/Oz GPU UTIL %z GPU MEM %z GPU MEM USAGErr0USAGEz-- / --z--)headersrS)r,rr) kwargs_listr)r7rHr$whoami list_jobsr[r\rVrr+rYmultiprocessingpool ThreadPooltimer _tabulatefetch_job_metricsiflatmap_unorderedrpopSTATS_UPDATE_MIN_INTERVALr)rr-rs parsed_idsr,r:rPrrrows_per_job_idrheaderlast_update_time total_rowsrdonernows r6 jobs_statsrs F F$*8C lmln^op^oTZ#-7f3DI4O^op pC'*eO # 99;(7[fSYCZCcCZc [ i :;"  " !"%"7"7v"7"[!.  "  #5T;O]h"i D$##FD1*.'))+C%%)BBAJ/00?cf[aKbCcKbc ci BC#& #j) 7 6' .q\  d9 7 6sU"1I I ;I' I '(I'I&I'?IAI'5I'I! (I'I'' I5zlist | ls | ps)z hf jobs lsz hf jobs ls -az&hf jobs ls --status running,schedulingzhf jobs ls --name training-v2z+hf jobs ls --label env=prod --label team=mlz%hf jobs ls --all --label hf-sandbox=1allz-az--allzWShow all Jobs (default shows running and scheduling). Cannot be combined with --status.r[z--statuszfOnly show Jobs with the given status. Comma-separated or repeated, e.g. `--status running,scheduling`.)rOrNz{Only show Jobs with the given `key=value` label. Repeat to require several labels, e.g. `--label env=prod --label team=ml`.zFOnly show Jobs with the given name (shortcut for `--label name=NAME`).limitz--limitzCMaximum number of Jobs to display. Set to 0 to show all (no limit).filterz--filterz2(Deprecated) Use `--status` and `--label` instead.c6[US9nU(a[R"SUS35 U(aU(a [S5e/n U=(d /H*n U R SU R S555 M, U (aU n O>U(aSn O4[ RR[ RR/n 0n U=(d /H/n SU ;a[S U S 35eU R S5upXU'M1 UbS U ;a [S 5eX.s"V5ETLDJJLL5Es55,NrzInvalid label filter 'z"': must be in the form 'key=value'rXz6Cannot filter by both `--name` and `--label name=...`.)r-r[rxFrrT durationsrgrVrTr,rxr docker_image image/spacer> created_atTcreatedr[r\r running_secsruntime)r,rXrrgrr[rrid_keyzOutput truncated to z4 Jobs. Use `--limit 0` to show all (or `--limit N`)., c3,# UH nSU3v M g7f)zstatus=Nr)rss r6rrs7,QWQC=,rc36# UHupSUSU3v M g7f)zlabel=rNr)rkvs r6rrs#:gXfPTPQVA3as;KXfzNo jobs matched filters: zHNo running jobs. Use `-a`/`--all` to include finished (and failed) jobs.)r$r+warningrrAr3rrr SCHEDULINGrr itertoolsislicerr*rrreplacerrHtablerEitemsrY)rr[rjrXrr-rsrr: raw_statusesrserver_statusesrxitemr jobs_iter truncatedjobs job_itemsrPjob_itemrcmd filters_msgs r6jobs_psr!7sGD 5 !C  x(p p  vIJJ!L2VU[[5EVV& #++1183F3F3L3LM F   d?3D69[\] ]ZZ_ s   V ST Tv RXR`\` aII qyI$$Y :; t9u I"G%/2chhsmOW||\hOiOih|4Sb9AA#sKot&ll84:??S-immN.KL"II\  'w.bcd  6))h7,7h:gX^XdXdXf:ghK HH0 > ? HH_ ` r8hardwarezhf jobs hardwarec [5nUR5n/nUHnSnUR(aGURRSURRSURR S3nUR (aSUR S3OSnUR (aSUR S-S 3OSnURURURURURURUUUS .5 M [R"U5 [R"S 5 g ) z(List available hardware options for JobsrTzx  ()$z.4ffree<z.2f)rXz pretty namecpuramstorage acceleratorzcost/minz cost/hourzLUse `hf jobs run --flavor ...` to request a specific hardware flavor.N)r$list_jobs_hardwarer,quantitymodelvram unit_cost_usdrHrX pretty_namer)r*ephemeral_storager+rrE)r: hardware_listrhwaccelerator_infocost_min cost_hours r6 jobs_hardwarer9s ,C**,M E >>"$.."9"9!:"R^^=Q=Qz*Job IDs to inspect (or 'namespace/job_id')c >/nUH!n[XA5upAURU5 M# Un[US9nUVs/sHoERXAS9PM nn[R "UVs/sH n[ [U5URS9PM" snSS9 gs snfs snf)z0Display detailed information on one or more JobsrurSrxrVrN) r7rHr$ inspect_jobr+r _surface_namer*rx)rr-rsrr,r:rrPs r6 jobs_inspectr@sJ8K&!G 5 !CNU VgFOO6O ?gD VIITXYTXS}/4SZZHTXYbfg WYs B''Bcancelzhf jobs cancel cx[X5up[US9nURXS9 [R"SUS9 g)z Cancel a JobrurSz Job cancelledrVN)r7r$ cancel_jobr+rI)r,r-rsr:s r6 jobs_cancelrEs75VGF 5 !CNN&N6JJ6*r8wait)zhf jobs wait z"hf jobs wait z"hf jobs ls -q | xargs hf jobs waitz,Job IDs to wait for (or 'namespace/job_id').zTMax time to wait: int with s (seconds, default), m (minutes), h (hours) or d (days).c 6/n[5nUH2n[Xb5upxURU5 URU5 M4 [ U5S:a0[ SSR S[U[S955-5eUR5nUb [U5OSn [US9n [R"S[ U5S 35n U RXIUS 9n U R![ U 5S35 [R""U V s/sHCoR$[U RR&5U RR(S.PME sn 5 U V s/sH.oRR&[*R,:wdM,U PM0 nn U(a<[ [ U5S[ U 5S3SR SU55-5eg![a" U R!S 5 [ S US 35Sef=fs sn fs sn f)aWait for one or more Jobs to reach a terminal state. Blocks until every Job has finished, then exits with code 0 if all Jobs completed successfully, or a non-zero exit code if any Job was canceled, errored or deleted. All Jobs must belong to the same namespace. rz0All Job IDs must be in the same namespace, got: r c38# UHn[U5v M g7fr)r)rnss r6rjobs_wait..2sF*EBB*Es)rNruz Waiting for z Job(s) to finish...)rnr-z Timed out.zTimed out after z waiting for Job(s) to finish.z Job(s) finished.)rVr\r^z of z' Job(s) did not complete successfully: c3l# UH*oRSURRS3v M, g7f)r$r%N)rVr[r\)rrPs r6rrJEs*KFS66("SZZ%5%5$6a8Fs24)setr7rHaddrrrrrrrr$r+r[rZ TimeoutErrorrrrVr\r^rr])rrnr-rsr namespacesr, parsed_idparsed_namespace timeout_secsr:r[rrPfaileds r6 jobs_waitrT s>JJ&B6&U# )$'( : >iiF&*EFF G   I.5.A>'*tL 5 !C ZZ,s:&77KL MF] IV KK3t9+./0IIhlmhladffs3::+;+;'<I[I[\hlmn! LTcZZ%5%59K9K%KcTF L 6{m4D {*Q RiiKFKK L   ] L!)'2PQRX\\] n LsG"A H'+HH",Hrx)z*hf jobs labels --name training-v2z8hf jobs labels --label env=prod --label team=mlzhf jobs labels --clearclearz--clearzRemove all labels from the job.cU(dUcU(d [S5eU(dUbU(a [S5e[X5up[US9nUb2U(d+URXS9R=(d 0n0UESU0EnO[ X!S9=(d 0nUR XUS9n [R"S U RURS5S 9 g) zfUpdate labels on a Job. Passing --label replaces all existing labels; passing --name alone keeps them.NePlease set a name with --name or at least one label with --label. To remove all labels, pass --clear.lCannot set a name or labels and clear them at the same time. Please use --name/--label or --clear, not both.rurSrXrv)r,rxr-Labels updatedrVrX) rr7r$r>rxrupdate_job_labelsr+rIrVr) r,rXrjrUr-rsr:current_labelsrxrPs r6 jobs_labelsr]Is" T\% s   !u z  5VGF 5 !C LSSYWY1N1FD1"54:  v  RCJJCFFF1CDr8)zhf jobs ssh zhf jobs ssh --dry-runz)hf jobs ssh -i ~/.ssh/id_ed25519 identity_filedry_runc[X5up[US9nURXS9nURRc [ S5eURR [;a0[ SURSURR S35eURR [R:wa[R"SURS URR S 35nURURU[R/S 9nURR [R:waAURS 5 [ SURS URR S35eURS5 [URR5n[UR SUR"3UR$UUS9 g)aSSH into a running Job. If the Job is not yet running, waits until it reaches the RUNNING state before connecting. Requires the Job to be started with SSH enabled (`hf jobs run --ssh ...`) and your SSH public key to be registered at https://huggingface.co/settings/keys. rurSNz[SSH is not enabled on this job. Start a job with SSH support using `hf jobs run --ssh ...`.zCannot SSH into job 'z%': job has already finished (stage: 'z').zWaiting for job 'z' to be running (stage: 'z')...)r,r-stagesz Job finished.z1': job finished before reaching RUNNING (stage: 'zJob is running.@)portr^r_)r7r$r>r[rrr\rrVrrr+rZrr r#usernamehostnamerc) r,r^r_r-rsr:rPr[rs r6jobs_sshrfns*5VGF 5 !C /// =C zz!tuu zz...svvh6[\_\f\f\l\l[mmpqrr zz8+++/x7PQTQ[Q[QaQaPbbghicff 8K[K[J\] ::  x// / KK ('x/`adakakaqaq`rruv   %&szz))*G    Ag../0 \\# r8zFRun UV scripts (Python with inline dependencies) on HF infrastructure.uvrv)z,hf jobs uv run --name my-script my_script.pyz$hf jobs uv run --detach my_script.pyz1hf jobs uv run ml_training.py --flavor a10g-smallz+hf jobs uv run --with transformers train.pyzNhf jobs uv run -v hf://org/my-model:/data -v hf://buckets/org/b:/mnt script.pyscript script_argswith_pythonc[XI5n[XZ5n[US9nURUU=(d /UUUUU[XvS9[ UUUS9UU U UUUS9n[ R "SURUR=(d 0RS5URS9 [Xg5(dbUR=(d 0RS5n[ R"SUS URRS URS 35 [UR R"[$5(aES R'S UR R"55n[ R"SU35 [UR R([*5(a;[ R"SURRS URS35 U (a]URRS UR3n[ R"SUSUS35 [ R"SUS35 g[-UU5 g)8Run a UV script (local file or URL) on HF infrastructurerurvrw)rhri dependenciesrkrfrhrirxr9rmrnrprqrrr-ryrXrzr|r}r0r~rc3,# UH nSU3v M g7frrrs r6rjobs_uv_run..rrrrrrrrrrN)r%r$ run_uv_jobrrMr+rIrVrxrr{rrErWrXrr[rrrrrra)rhrirfrmrhrirXrjrLrkrlrnrorprqrrr-rsrjrkrrr:rPrrrs r6 jobs_uv_runrrsDC*G6K 5 !C ..%2  2+FyQ +  C"JJ}szz/?R.D.DV.LRURYRYZ d * *ZZ%2**62  yk*"yy~~.ax7R T #**(($//yyFszz/E/EFF ghlgmno#**$$c** $SYY^^$4AcffX=cde YY^^$AcffX. ( 1WX_W``rst %gY.KLM!#s+r8z,Create and manage scheduled Jobs on the Hub. scheduledzRhf jobs scheduled run "0 0 * * *" --name daily-script python:3.12 python script.pyschedulesuspend concurrencyc[XZ5n[Xk5n[US9nURUUUUUUU[XS9[ U UUS9U U UUUS9n[ R "SURURR=(d 0RS5S9 [Xx5(dlURR=(d 0RS5n[ R"SUS URRS URS 35 [ R"S URRS URS 35 g)zSchedule a Job.rurvrw)rfrgrtrurvrhrirxr9rmrnrprrr-Scheduled Job createdrXrZScheduled Job auto-named '2'. Pass `--name` or run `hf jobs scheduled labels r0r~Use `hf jobs scheduled inspect ` to view its details.N)r%r$create_scheduled_jobrrMr+rIrVjob_specrxrrrErWrX)rtrfrgrurvrhrirXrjrLrkrlrmrnrprrr-rsrrr: scheduled_jobrs r6 scheduled_runrsE4C*G6K 5 !C,,  2+FyQ+-M JJ&=+;+;=CYCYC`C`CfdfBkBklrBst d * *"++228b==fE  ( 4))6)<)<)A)A(B!MDTDTCUUp r HH.}/B/B/G/G.H-JZJZI[[q rsr8zhf jobs scheduled lsz1Show all scheduled Jobs (default hides suspended)z>Filter output based on conditions provided (format: key=value)c[US9nURUS9n/nU=(d /HnSU;aeURSS5upURS5(aSn USSnOSn UR UR 5XR 545 Mn[ R"S US 35 M /n UHn U R=(d S n U(d U (aM(U RR=(d S nU RR=(d /nU(aS RU5OS nU RR=(d 0RS5=(d S nU RUU[!U 5US.n[#UU5(dMU R U 5 M /nU GHxn[%U5nURS5=(d 0nURS5=(d 0nURS5nURS5=(d /nURS5=(d 0RS5=(d S US'URS5=(d S US'U(aS RU5OS US'U(a.URS5(aUSSSR'SS 5OS US'URS5(aUSSSR'SS 5OS US'URS5=(d S US'UR U5 GM{ [ R("U/SQSS 9 U(d8U(a1S!RS"U55n[ R*"S#U35 U(a=US$Sn[ R,"S%US&35 [ R,"S'US(35 gg))zList scheduled Jobsrurrr!rNz Ignoring invalid filter format 'z'. Use key=value format.Frr>rX)rVrXrfrurgr~r[last_jobrgrxrratrrlast_runnext_job_run_atnext_runru)rVrXrtrrgrrrurVrr c36# UHupo1UU3v M g7frr)rr ors r6rscheduled_ps..zsDGq#aS Grz#No scheduled jobs matched filters: rr{z(` to view details about a scheduled job.zUse `hf jobs scheduled trigger z)` to trigger a scheduled job immediately.)r$list_scheduled_jobsr3endswithrHrr+rrur~rrgrrxrrVrrr*rrrYrE)rr-rsrr:scheduled_jobsrfrrop filtered_jobsrruimage_or_spacer command_strjob_namepropsrsjrr~ status_dictrr  first_item_ids r6 scheduled_psr'sH, 5 !C,,y,AN*,G \r\ !8aJC||C  #2h NNCIIK[[]; < KK:1#=UV WM' ''05w &//<<E$$,,2'*chhsm !**117R<:Ce]+.#((3-EYDLQYQ]Q]^bQcQc8D>#2.66sC@inZEP__UfEgEgK) *3B / 7 7S Amr Z((9-6Y T II g WiiDGDD  6{mDE a  2=/Aijk 2=/Ajkl r8zhf jobs scheduled inspect scheduled_job_idsz>Scheduled Job IDs to inspect (or 'namespace/scheduled_job_id')c T/nUH!n[XA5upAURU5 M# Un[US9nUVs/sHnURXaS9PM nn[R "UVs/sH*n[ [U5URRS9PM, snSS9 gs snfs snf)z:Display detailed information on one or more scheduled Jobsruscheduled_job_idr-r<rVr=N) r7rHr$inspect_scheduled_jobr+rr?r*r~rx) rr-rsrr,r:rrrs r6scheduled_inspectrsJ#8K&!$# 5 !C!2 1  !!3C!Y 1IIZhiZhTV}/3BKKrcx[X5up[US9nURXS9 [R"SUS9 g)zDelete a scheduled Job.rurzScheduled Job deletedrCN)r7r$delete_scheduled_jobr+rIrr-rsr:s r6scheduled_deleter?#??O"[ 5 !C.>TJJ&+;c[X5up[US9nURXS9 [R"SUS9 [R "SUS35 g)z Suspend (pause) a scheduled Job.rurzScheduled Job suspendedrCzUse `hf jobs scheduled resume z` to resume it.N)r7r$suspend_scheduled_jobr+rIrErs r6scheduled_suspendrsW#??O"[ 5 !C/?UJJ(-=>HH-.>-? OPr8resumezhf jobs scheduled resume cx[X5up[US9nURXS9 [R"SUS9 g)z!Resume (unpause) a scheduled Job.rurzScheduled Job resumedrCN)r7r$resume_scheduled_jobr+rIrs r6scheduled_resumerrr8triggerzhf jobs scheduled trigger c[X5up[US9nURXS9n[R"SUR UR S9 [R"SURRSUR S35 g) zJTrigger a scheduled Job to run immediately (does not change the schedule).rurzScheduled Job triggered)rVr{rr0z` to stream logs.N) r7r$trigger_scheduled_jobr+rIrVr{rErWrX)rr-rsr:rPs r6scheduled_triggerrst#??O"[ 5 !C # #5E # [CJJ(SVVAHH$SYY^^$4AcffX=N OPr8)z1hf jobs scheduled labels --name daily-scriptz>hf jobs scheduled labels --label env=prod --label team=mlz%hf jobs scheduled labels --clearz)Remove all labels from the scheduled job.cU(dUcU(d [S5eU(dUbU(a [S5e[X5up[US9nUb<U(d5URXS9RR =(d 0n0UESU0EnO[ X!S9=(d 0nURXUS9n [R"S U RURS5S 9 g) zpUpdate labels on a scheduled Job. Passing --label replaces all existing labels; passing --name alone keeps them.NrWrXrurrXrv)rrxr-rYrZ) rr7r$rr~rxrupdate_scheduled_job_labelsr+rIrVr) rrXrjrUr-rsr:r\rxrs r6scheduled_labelsrs" T\% s   !u z  #??O"[ 5 !C   % %7G % ] f f m m sqs 2N1FD1"54:33)I4MJJM$4$46::f;MNr8z)Schedule UV scripts on HF infrastructure.zBhf jobs scheduled uv run "0 0 * * *" --name daily-script script.pyzaxG] ^_r8rcLU=(d 0RS5nUcU$SU0UE$)zPromote the `name` label to a top-level `name` field for display. The `name` is kept inside `labels` too (the dataclasses and API payloads are unchanged); this only makes it a first-class column/field in command outputs. No-op when there is no name. rX)r)rrxrXs r6r?r?Bs2 Lb  f %D | D !D !!r8cNUSL=(d [SU=(d /55$)zLWhether the user explicitly named the Job (via `--name` or a `name=` label).Nc3P# UHoRSS5SS:Hv M g7f)rrrrXN)r3)rrs r6r%_has_explicit_name..Ps#"[{t::c1#5a#8F#B{s$&)any)rXrjs r6rrNs$ t  [s"[u{XZ{"[[[r8cU(dUcg0nU=(d /H%nSU;aURSS5OUS4upEXRU'M' UbSU;a [S5eXS'U$)zParse label key-value pairs from CLI arguments. Args: labels: List of label strings in KEY=VALUE format. If KEY only, then VALUE is set to empty string. Returns: Dictionary mapping label keys to values, or None if no labels or name provided. NrrrTrXz4--name and --label name=... cannot both be provided.)r3r)rxrX labels_map label_varrrs r6rrSst dl!#J\r\ 03y0@Y__S!,yRTo 3"  Z QR R!6 r8rrc  [/UQUP76Vs/sHn[SU55PM nn[[R"5R[ U5S-5n[ U5[ U5-U:aUR[U55nX5==S-ss'[ U5[ U5-U::a!U[ U5- [ U5- X5-X5'[ U5[ U5-U:aMS[ U5-R"U6n/nURUR"U65 URUR"UVs/sHnSU-PM sn65 UHun [X5V V s/sH<up[ [U 55U :a[U 5SU S- S-O [U 5PM> n n n URUR"U 65 Mw S RU5$s snfs snfs sn n f) zy Inspired by: - stackoverflow.com/a/8356620/593036 - stackoverflow.com/questions/9535954/printing-lists-as-tabular-data c3J# UHn[[U55v M g7fr)rr)rxs r6r_tabulate..ps/3ac#a&kk3s!# rz{{:{}}} -Nz...r) rmaxshutilget_terminal_sizecolumnsrsumindexformatrHrr) rrcol col_widthsterminal_widthcol_to_minimize row_formatlineswrr col_widthrow_format_argss r6rris 9$**3z?;#)# w<#j/ )^ ;*83z?*JSQX\*Y\f\w*wJ ' g,Z (> 9 s7|+33Z@J E LL""G,- LL""j$AjS1Wj$ABC!$C 4 4 033q6{Y/FCF?Y] #e +CPQF R 4    Z&&89  99U #P%B sG6G; =AHrqueuefunc.kwargscDU"S0UD6HnURU5 M g)Nr)put)rrrrIs r6_write_generator_to_queuers.. &!r8rrc #F# [5nUVs/sHo@R[X1U45PM nnURSS9v Ms snf![a1 [ SU55(aUR 5(aONAf=f![a Of=fUVs/sHofRSS9PM Os snf ng![Ra gf=f!UVs/sHofRSS9PM Os snf nf![Ra ff=f=f7f)a# Takes a function that returns an iterable of items, and run it in parallel using threads to return the flattened iterable of items as they arrive. This is inspired by those three `map()` variants, and is the mix of all three: * `imap()`: like `map()` but returns an iterable instead of a list of results * `imap_unordered()`: like `imap()` but the output is sorted by time of arrival * `flatmap()`: like `map()` but given a function which returns a list, `flatmap()` returns the flattened list that is the concatenation of all the output lists g?)rnc3@# UHoR5v M g7fr)ready)r async_results r6r%iflatmap_unordered..sN ))++ sN) r apply_asyncrrrremptyKeyboardInterruptrrN)rrrrr async_resultsrs r6rrsgEfqrfq\b%%&?%vAVWfqMr iii--s  N NNNSXS^S^S`S`      @M N  d  + N++    @M N  d  + N++   sD!!A D!B AB D!6B B CB B  B BCBCC"B;:CD!CD!CD!DD#C<;DDDDDDD!)NNNNNNNNNFNFNNN)FNNN)NNN)FNNNrNNN)r.N)NN)NNFNN)NFNN)NNNNNNNNNNNFNFNNNNN)NNNNNNNNNNNNNNN)NNNNNNNNNNNNNNNNNNN)__doc__rrmultiprocessing.poolrrcollections.abcrrrpathlibrrrrtypingr r r urllib.parser huggingface_hubr rrrrrhuggingface_hub._jobs_apirhuggingface_hub.errorsrhuggingface_hub.utilsr$huggingface_hub.utils._cache_managerrhuggingface_hub.utils._hf_urisrhuggingface_hub.utils._parsingrr _cli_utilsrrrrrr r!r"r#r$r%r&r' _frameworkr(r)_outputr*r+ get_logger__name__loggerrtupler7rrMrImageArgImageOpt FlavorOpt LabelsOptNameOpt TimeoutOptbool DetachOpt NamespaceOptResourceGroupIdOptint ExposeOpt SshEnabledOptWithOpt PythonOpt SuspendOptConcurrencyOpt ScheduleArg ScriptArg ScriptArgsArg CommandArgJobIdArg JobIdsArgScheduledJobIdArg JobVolumesOptjobs_clirargrrrrrrrr!r9r@rErTr]rfuv_app add_grouprr scheduled_apprrrrrrrrscheduled_uv_apprr?rrrrrrrrrr8r6rsLG .**!TT9+)=7J),   H %..t.cSVY]S]oH^.8) #Y )',)9X ]a '3'4' !)$sCx.!9JNs) eD#tDsO44568 '%=$>?"A' A'A' A' A'@A'H  &     " aFa    j   Fa  S D !(+y   Fa"  S D  O   #Fa2  d  Y   3Fa@   V   AFaNOFaP QFaR  S D  E   SFab cFa FaR *(:';<]=]6 )'A&BC#h  S =  hh h hDh* (&?%@A# +  + +  + +B +  ( "4  S ?  4  d g  4 4  4  4 4 n  X]" E E E E T6)2STT U E  E  E EE:  )-!" # #%## #  #  ##L d e6% .5 "& #',0")=, =,=, =,  =,  =,  =, =, =, =,=,!=,=, =, =, =, *!=,"#=,$ %=,& '=,( )=,* +=, =,@#QR ={3 .5b c"& #',0"%0t0t 0t0t 0t  0t  0t0t 0t 0t 0t0t!0t 0t0t 0t *!0t"#0t$ %0t& '0t  0tf'3I2JK " %Wm    D   WmWm Wm  S D  Q   Wm& 'WmLWmty,L+MN#x  S Q  xx x xOx0x+J*KL# =' = =  = =M =y,L+MN# Q' Q Q  Q QO Qx+J*KL# =' = =  = =M =y,L+MN# Q' Q Q  Q QO Q bg" O'O O O T6)2]^^ _ O  O  O OOB!&QR (t4 .5LF"&"& #',0"+6`6` 6`6` 6`  6`  6` 6` 6`6` 6` 6` 6`6`!6`6` !6`"*#6`$%6`& '6`( )6`* +6`, -6`6`x "S#X "4S>D3H "TRUWZRZ^ "\S4Z\S D0@\T\ GKd3i$.ttTWY\T\~`dOd,DcCi)DI#6 CLU1XXc8A;>N5OY]bf     ) ) 3 # $d  a[ r8