+ PjŸ Rt^RIt^RIt^RIt^RIt^RIt^RIHtHt^RI H t ^RI H t ^RI H t Ht^RIHtHtHt^RIHt^RIHtHtHtHtHtHt^R IHt^R IHt^R I H!t!^R I"H#t#^R I$H%t%^RI&H't'H(t(^RI)H*t*H+t+H,t,H-t-H.t.H/t/H0t0H1t1H2t2H3t3H4t4H5t5H6t6^RI7H8t8H9t9^RI:H;t;H4t?RRlt@RRltARtB]]C]8!RR73,tD]]CR,]9!RR73,tE]]CR,]9!R].!]4R73,tF]]G]C,R,]9!RRRR73,tH]]CR,]9!RR73,tI]]J]9!R R!R"R73,tK]]CR,]9!R#R73,tL]]G]M,R,]9!R$R%R73,tN]]J]9!R&R'R73,tO]]G]C,R,]9!R(R)R73,tP]]CR,]9!R*R+R,R73,tQ]]JR,]9!R-R73,tR]]JR,]9!R.R73,tS]]C]8!R/R73,tT]]C]8!R0R73,tU]]G]C,R,]8!R1R73,tV]]G]C,]8!R2R73,tW]]C]8!R3R73,tX]]G]C,R,]8!R4R73,tY]]C]8!R5R73,tZ]]G]C,R,]9!R6R7R8R73,t[]6!R9R7t\R:R;lt]]\PR/.ROR?7RR@RAll4t_]\PRB.RORC7RRDREll4t`RFRGltaRHRIltbRJRKltc]\PRLRM.RC7RRNROll4td]\PRP.RORC7RRQRRll4te]\PRSRT.RC7RURVl4tf]\PRWRX.RC7RRYRZll4tg]\PR[R\.RC7RR]R^ll4th]\PR_.RORC7RR`Rall4ti]\PRbRcRd.RC7RReRfll4tj]\PRg.RORC7RRhRill4tk]6!RjR7tl]\P]lRkRl7]lPR/.ROR?7RRmRnll4tn]6!RoR7to]\P]oRpRl7]oPR/Rq.R?7RRrRsll4tp]oPRPRt.RC7RRuRvll4tq]oPRWRw.RC7RRxRyll4tr]oPRzR{.RC7RR|R}ll4ts]oPR~R.RC7RRRll4tt]oPRR.RC7RRRll4tu]oPRR.RC7RRRll4tv]oPRbRR.RC7RRRll4tw]6!RR7tx]oP]xRkRl7]xPR/RR.R?7RRRll4tyRRltzRRlt{]!R4t|RRlt}RRlt~R#)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_dictoutc zV^8dQhR\R\R,R\\\R,3,/#)job_id namespaceNreturn)strtuple)formats"q/Users/ahmed/devFolder/Ultron/claude-voice/gateway/.venv/lib/python3.14/site-packages/huggingface_hub/cli/jobs.py __annotate__r3:s5...t.cSVY]S]oH^.c*V'g \R4hVPR4^8d\RV R24hRV9dW3#VPR^4wr#V'd V'g\RV R24hVeW8wd\RV RV R24hW23#)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./zr?r-resultraw_specrL mount_pathrCvolumes &$$ r2_parse_and_sync_job_volumesrSVsK F   y44 5 5 MM- 399r : )5X(L%I  5hZ@CD F|&&(//11!&*zz $$  #,#8id %    u $ HH:,'228--&++aPVxY   f78 Mr4g?zThe Docker image to use.helpz.Use a custom Docker image with `uv` installed.zcFlavor for the hardware. Run 'hf jobs hardware' to list available flavors. Defaults to `cpu-basic`.)rU click_type-l--labelz3Set labels. E.g. --label KEY=VALUE or --label LABELzPMax duration: int with s (seconds, default), m (minutes), h (hours) or d (days).z-dz--detachz3Run the Job in the background and print the Job ID.zVThe namespace where the job will be running. Defaults to the current user's namespace.z--exposezExpose a container port through the jobs proxy. Repeat the flag for multiple ports (e.g. `--expose 8000 --expose 8001`). Each exposed port is reachable on the public jobs domain; access requires an HF token with read access to the job's namespace.z--sshzMake the job's container reachable over SSH. Connect with `hf jobs ssh `. 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.c4V^8dQhR\R\RR/#)r+r?jobr.N)r r)r1s"r2r3r3.s! * *u *7 *t *r4crVPVPVPPRR7Fp\P !V4K VP VPVPPR7pVPP\P8wdjVPP'dRVPP 2MRp\RVP RVPP RV 24h\P !RVP R 24R #) 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 'r7z completedN) fetch_job_logsidownernamer)text wait_for_jobstatusstager COMPLETEDmessager)r?rZlogfinalrhs&& r2_stream_logs_and_check_statusrk.s!!399>>RV!W  X   CFFciinn  EE ||X///161E1E1EBu||++,-2ehhZ'=ell>P>P=QQRSZR[\]]HHtEHH:Z ()r4runignore_unknown_optionsT)context_settingsexamplesc V^8dQhR\R\R\R\R\R\ R\ R\R \R \R \R \R \R\R\RR/#)r+imagecommandenvsecretslabelrRenv_file secrets_fileflavortimeoutdetachexposesshr-tokenr.N)ImageArg CommandArgrr LabelsOpt JobVolumesOptrr FlavorOpt TimeoutOpt DetachOpt ExposeOpt SshEnabledOpt NamespaceOptr )r1s"r2r3r3Es.,., ., ., ., .,  .,  .,.,!., .,., ., ., .,., .,  !.,r4c\W&4p\W74p\VR7pVPVVVV\V4\ VVV R7VV V V V R7 p\ P !RVPVPR7\VPP\4'dFRPRVPP44p\ P!RV 24\VPP\ 4'd<\ P!R VP"P$ R VP R 24V 'd_VP"P$ R VP 2p\ P!R V R V R24\ P!RV R24R#\'VV4R#)z Run a Job.r}r?r-) rqrrrsrtlabelsr>rxryr{r|r- Job startedr`url c3,"TF pRV 2xK R#5iz N.0rs& r2 jobs_run..jF/E2cU/ESExposed ports are reachable at (requires an HF token with read access to the job): Use `hf jobs ssh r6&` 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_maprSr)rOr`r isinstancere expose_urlsr@joinrKssh_urlr/rarbrk)rqrrrsrtrurRrvrwrxryrzr{r|r-r}env_map secrets_mapr?rZurlsjob_refs&&&&&&&&&&&&&&& r2jobs_runr:sn:C*G6K 5 !C ++  '+FyQ   CJJ}SWW5#**(($//yyFszz/E/EFF ghlgmno#**$$c** $SYY^^$4AcffX=cde YY^^$AcffX. ( 1WX_W``rst %gY.KLM!#s+r4logs)roc V^8dQhR\R\\\RRRR73,R\\R,\R R R R73,R \ R \ RR/#)r+r,r\-fz--followzqFollow log output (stream until the job completes). Without this flag, only currently available logs are printed.rTtailNz-nz--tailzvNumber of lines to show from the end of the logs. When combined with --follow, starts streaming from the last N lines.r-r}r.)JobIdArgrboolr'intrr )r1s"r2r3r3s&x&x &x    E   &x  d   J   &x$%&x& '&x( )&xr4c\W4wr\VR7pVPWWR7pVFp\P!V4K V'd.V'dV RV 2MTp\P !RV R24R#R#)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. r)r,r-r\rr6z#Stream ended. Run `hf jobs inspect z6` to check the final status (e.g. COMPLETED or ERROR).N)r<r"r_r)rcrK) r,r\rr-r}r?rrirs &&&&& r2 jobs_logsrvsyN5VGF 5 !C   V  [D   -6YKq)F 6wi?uvwr4cV^8dQhR\\\3,R\\\\\3,,R\/#)r+job_propertiesfiltersr.)dictr/r@r0r)r1s"r2r3r3s;  T#s(^ d5cSVCW>X ]a r4cVFrwr#pVPV4pVf VR8XdK$R#\VP4VP44pVR8Xd V'dVR8XgKgV'gKqR# R#)z5Check if scheduled job matches all specified filters.!=F=T)getrlower)rrkeyop_strpatternvaluematchs&& r2_matches_filtersrsf 'W""3' =~ w}}7 cM%Vt^!( r4c(V^8dQhR\RR/#)r+nr.N)r)r1s"r2r3r3s''3'4'r4cJRpRp\V4Fp\WR7K R#)zz)endN)rangeprint)rLINE_UP LINE_CLEARis& r2 _clear_liners"GJ 1X g&r4cV^8dQhR\R\\\\3,,R\\,R\\ \ \\\\\,,,3,,/#)r+r,metrics_stream table_headersr.)r/rrr r@r0rr)r1s"r2r3r3s[ !)$sCx.!9JNs) eD#tDsO4456r4c #"VEFpVVR, R2\VR,R, ^4\^dVR,,VR,, ^4 R2\VR,4 R\VR,4 R2\VR,4 R \VR ,4 R 2.pVR ,'d\VR ,\4'dV.R .\ V4,.\ VR ,4^, ,,p\ V\ VR ,44FzwrFVR ,V,pVVR, R2\^dVR,,VR,, ^4 R2\VR,4 R\VR,4 R2., pK| M-VR.\ V4\ V4, ,, pV.pRW3xEK RV.3xR#5i) cpu_usage_pct%cpu_millicoresg@@memory_used_bytesmemory_total_byteszB / Brx_bpszbps / tx_bpsbpsgpusr^ utilizationN/AFTN)roundrrrlenzipsorted)r,rrmetricsrowrowsgpu_idgpus&&& r2_get_jobs_stats_rowsrs" '( * '*+f4a 8S7#677'BV:WWYZ[\\] ^G$789:$|GThLi?j>kkl mGH-./vl78CT6U5VVY Z   6??z'&/4@@5RD3s8O,GFO0Dq0HIID"4)@A fof-=)*!,S3':#;;cBV>WWYZ[\\]^#C(;$<=>dc@V^8dQhR\R\R\RR/#)r+job_idsr-r}r.N) JobIdsArgrr )r1s"r2r3r3s6A'A' A'A' A' A'r4c pVe,.pVF!p\WA4wrAVPV4K# Tp\VR7pVfVP4R,pVf]VP VR7Uu.uF@pVP 'dVP P MRR9gK4VPNKB pp\V4^8Xd\P!R4R#.ROp\PP\V44;_uu_4p/p VF:pV.p YR,U u.uFp RV 9gR V 9dR MR NK up , p V .W&K< \P!4p V UU u.uFqIV,FqNK K p pp \\!WR 74VUu.uFpR VRVP#WAR7RV/NK pp\%V\&VR7FwrpV'dV P)VR4MVW&\P!4pVV , \*8gKN\-^\V 4,4V UU u.uFqIV,FqNK K p pp \\!WR 74Tp K RRR4R#uupiuup iuup piuupiuup pi +'giR#;i)z7Fetch the resource usage statistics and metrics of JobsNrrbr-UNKNOWNzNo running jobs found:NNr6USAGEz-- / --z--)headersr,rr]r) kwargs_list)RUNNINGUPDATING) zJOB IDzCPU %zNUM CPUzMEM %z MEM USAGEzNET I/Oz GPU UTIL %z GPU MEM %z GPU MEM USAGE)r<rNr"whoami list_jobsrerfr`rr)rcmultiprocessingpool ThreadPooltimer _tabulatefetch_job_metricsiflatmap_unorderedrpopSTATS_UPDATE_MIN_INTERVALr)rr-r} parsed_idsr,r?rZrrrows_per_job_idrheaderlast_update_time total_rowsrdonernows&&& r2 jobs_statsrs F F$*8C ln^op^oTZ#-7f3DI4O^op pC'*eO # 99;(7[fSYCZCZCcCZc [ i :;"  " & #"7"7v"7"[  "  #5T;O]h"i D$##FD1*.'))+C%%)BBAJ/00?cf[aKbKbCcKbc ci BC#& #j) 7 6' .q\  d9 7 6 6s[/J J %J J$)J ,J$0J J$%!JAJ$( J$J !J$J$$ J5 zlist | ls | pscV^8dQhR\\\RRRR73,R\\\,R,\R\ \ 4R R 73,R \\\,R,\R R RR73,R\\\RRR73,R\R\R\\\,R,\RRRR73,RR/#)r+all-a--allzWShow all Jobs (default shows running and scheduling). Cannot be combined with --status.rTreNz--statuszfOnly show Jobs with the given status. Comma-separated or repeated, e.g. `--status running,scheduling`.)rVrUrurWrXz{Only show Jobs with the given `key=value` label. Repeat to require several labels, e.g. `--label env=prod --label team=ml`.limitz--limitzCMaximum number of Jobs to display. Set to 0 to show all (no limit).r-r}filterr--filterz2(Deprecated) Use `--status` and `--label` instead.r.) rrr'r@r/rrrrr )r1s"r2r3r3(s,xaxa    j   xa  S D !(+y   xa"  S D  O   #xa2   V   3xa@AxaB CxaD  S D  E   ExaT Uxar4c\VR7pV'd\P!RV R24V'dV'd \R4h.pT;'g.F*p VP RV P R444K, V'dTp M?V'dRp M4\ PP\ PP.p /p T;'g.F0p RV 9d\R V R 24hV P R4wrWV &K2 TPYJT ;'gRR 7pR pV^8d?\\P!W^,44p\V4V8dR pVRVpM \V4p.pVEF.p\V4pVP!R4;'g/pVP!R4;'g.pVP!RR4VR&VP!R4;'gRVR&V'dRP#V4MRVR&VP!R4'd!VR,R,P%RR4MRVR&VP!R4;'g/P!RR4VR&\'VP!R44VR&VP)V4EK1 \P*!V.R(ORR 7V'd\P,!R!V R"24V'gV'g V 'dMR#P#.R$V4OR%V P/44O4p\P0!R&V 24R#V'g\P,!R'4R#R#R#))zList Jobs. Use `--status` to filter by status (see [`JobStage`] for possible values) and `--label` to filter by `key=value` labels. A Job must match every filter to be listed. rzIgnoring filter 'zc'. `-f`/`--filter` is deprecated and will be removed in a future release. Use `--status`/`--label`.z0`-a`/`--all` cannot be combined with `--status`.c3p"TF,qP4'gKVP4xK. R#5iN)strip)rparts& r2rjobs_ps..fs"V5ETLDJJLL5Es66,NrzInvalid label filter 'z"': must be in the form 'key=value')r-rerFT durationsrrr`r^r, docker_imager image/spacerD created_atNNTcreatedrerfr running_secsruntimerid_keyzOutput truncated to z4 Jobs. Use `--limit 0` to show all (or `--limit N`)., c3,"TF pRV 2xK R#5i)zstatus=Nr)rss& r2rrs7,QWQC=,rc36"TFwrRV RV 2xK R#5i)zlabel=rNr)rkvs& r2rrs#:gXfPTPQVA3as;KXfzNo jobs matched filters: zHNo running jobs. Use `-a`/`--all` to include finished (and failed) jobs.)r,rrrrrer)r"r)warningrrGr9rrr SCHEDULINGrr@ itertoolsislicerr(rrreplacerrNtablerKitemsrc)r rerur r-r}r r? raw_statusesrserver_statusesritemr jobs_iter truncatedjobs job_itemsrZjob_itemrcmd filters_msgs&&&&&&& r2jobs_psr:st 5 !C  x(p p  vIJJ!L2VU[[5EVV& #++1183F3F3L3LM F   d?3D69[\] ]ZZ_ s   RXR`R`\` aII qyI$$Y :; t9u I"G"G%/2chhsmOW||\hOiOih|4S9AA#sKot&ll84::??S-immN.KL"IIT  'w.bcd  6))h7,7h:gX^XdXdXf:ghK HH0 > ? HH_ ` r4hardwarezhf jobs hardwarecV^8dQhRR/#)r+r.Nr)r1s"r2r3r3s]]t]r4c\4pVP4p.pVEFpRpVP'dHVPP RVPP RVPP R2pVP 'dRVP R 2MRpVP 'dRVP ^<,R 2MRpVPR VPR VPR VPR VPR VPRVRVRV/4EK \P!V4\P!R4R#)z(List available hardware options for Jobsr^zx  ()$z.4ffreez.2frbz pretty namecpuramstorage acceleratorzcost/minz cost/hourzLUse `hf jobs run --flavor ...` to request a specific hardware flavor.N)r"list_jobs_hardwarerEquantitymodelvram unit_cost_usdrNrb pretty_namerBrCephemeral_storager)r.rK)r? hardware_listr/hwaccelerator_infocost_min cost_hours r2 jobs_hardwarerRs* ,C**,M E >>>"$.."9"9!:"R^^=Q=QcV^8dQhR\\\,\RR73,R\R\ RR/#)r+rz*Job IDs to inspect (or 'namespace/job_id')rTr-r}r.Nrr@r/r&rr )r1s"r2r3r3sN99  S =  99 9 9r4c&.pVF!p\WA4wrAVPV4K# Tp\VR7pVUu.uFqEPWAR7NK pp\P !VUu.uFp\ V4NK up4R#uupiuupi)z0Display detailed information on one or more Jobsrr]N)r<rNr" inspect_jobr)r.r()rr-r}rr,r?r5rZs&&& r2 jobs_inspectrXsJ8K&!G 5 !CNU VgFOO6O ?gD VII$7$3!#&$78 W7s B ,Bcancelzhf jobs cancel c@V^8dQhR\R\R\RR/#)r+r,r-r}r.N)rrr )r1s"r2r3r3s0 + +  + +  + +r4c\W4wr\VR7pVPWR7\P!RVR7R#)z Cancel a Jobrr]z Job cancelledr`N)r<r" cancel_jobr)rO)r,r-r}r?s&&& r2 jobs_cancelr^s75VGF 5 !CNN&N6JJ6*r4waitc V^8dQhR\\\,\RR73,R\\R,\ RR73,R\ R\ R R/#) r+rz,Job IDs to wait for (or 'namespace/job_id').rTryNzTMax time to wait: int with s (seconds, default), m (minutes), h (hours) or d (days).r-r}r.)rr@r/r&r'rr )r1s"r2r3r3st4 4  S ?  4  d g  4 4  4  4 r4c f.p\4pVF2p\Wb4wrxVPV4VPV4K4 \ V4^8d8\ RRP R\V\R744,4hVP4pVe \V4MRp \VR7p \P!R\ V4 R24p V PWIVR 7p T P!\ T 4 R 24\P"!T U u.uFFp RT P$R\T PP&4RT PP(/NKH up 4T U u.uF/qPP&\*P,8wgK-T NK1 pp T'dA\ \ T4 R\ T 4 R2RP RT44,4hR# \d#T P!R 4\ R T R 24Rhi;iuup iuup i)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. z0All Job IDs must be in the same namespace, got: r"c38"TFp\V4xK R#5ir)r/)rnss& r2rjobs_wait.. sF*EBB*Es)rNrz Waiting for z Job(s) to finish...)ryr-z Timed out.zTimed out after z waiting for Job(s) to finish.z Job(s) finished.r`rfrhz of z' Job(s) did not complete successfully: c3l"TF*qP RVPP R2xK, R#5i)r>r?N)r`rerf)rrZs& r2rrds*KFS66("SZZ%5%5$6a8Fs24)setr<rNaddrrrrr/rrr"r)rerd TimeoutErrorrr.r`rfrhrrg)rryr-r}r namespacesr, parsed_idparsed_namespace timeout_secsr?rer5rZfaileds&&&& r2 jobs_waitrns>JJ&B6&U# )$'( : >iiF&*EFF G   I.5.A>'*tL 5 !C ZZ,s:&77KL MF] IV KK3t9+./0IIhlmhladcffgs3::+;+;' --label env=prod --label team=mlzhf jobs labels --clearc V^8dQhR\R\R\\\ RRR73,R\ R\ R R /#) r+r,ruclear--clearzRemove all labels from the job.rTr-r}r.N)rrrrr'rr )r1s"r2r3r3(sV,, , , T6)2STT U, ,  ,  ,r4c8V'gV'g \R4hV'dV'd \R4h\W4wr\V4;'g/p\VR7pVP WVR7p\ P !RVPR7R#)z5Update labels on a Job. Replaces all existing labels.OPlease set at least one label with --label. To remove all labels, pass --clear.bCannot set labels and clear them at the same time. Please use either --label or --clear, not both.r)r,rr-Labels updatedr\N)rr<rr"update_job_labelsr)rOr`)r,rurpr-r}rr?rZs&&&&& r2 jobs_labelsrw!s} hii  p  5VGF u % + +F 5 !C  v  RCJJCFF+r4r|c XV^8dQhR\R\R\R\R\RR/#)r+r, identity_filedry_runr-r}r.N)rrrrr )r1s"r2r3r3EsD## #%## #  #  #r4c\W4wr\VR7pVPWR7pVPPf \ R4hVPP \9d1\ RVP RVPP R24hVPP \P8wd\P!RVP R VPP R 24pVPVPV\P.R 7pVPP \P8wdBVPR 4\ RVP R VPP R24hVPR4\VPP4p\VP RVP" 2VP$VVR7R#)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. rr]Nz[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.@)portryrz)r<r"rWrerrrfrr`rrr)rdrr r!usernamehostnamer~) r,ryrzr-r}r?rZrers &&&&& r2jobs_sshr=s*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 \\# r4zFRun UV scripts (Python with inline dependencies) on HF infrastructure.uv)rbc&V^8dQhR\R\R\R\R\R\ R\ R\R \R \R \R \R \R\R\R\R\ R\"RR/#)r+script script_argsrqrxrsrtrurRrvrwryrzr{r|r-r}with_pythonr.N) ScriptArg ScriptArgsArgImageOptrrrrrrrrrrrrr WithOpt PythonOpt)r1s"r2r3r3zs4,4, 4,4, 4,  4,  4,  4, 4, 4,4,!4,4, 4, 4, 4,4, !4," #4,$ %4,& '4,r4c\WH4p\WY4p\VR7pTPTT;'g.VVVVV\V4\ VVVR7VV V V VR7p\ P !RVPVPR7\VPP\4'dFRPRVPP44p\ P!RV 24\VPP\ 4'd<\ P!R VP"P$ R VP R 24V 'd_VP"P$ R VP 2p\ P!R V R V R24\ P!RV R24R#\'VV4R#)8Run a UV script (local file or URL) on HF infrastructurerr)rr dependenciesrrqrsrtrr>rxryr{r|r-rrrc3,"TF pRV 2xK R#5irrrs& r2rjobs_uv_run..rrrrr6rrrrrrN)r#r" run_uv_jobrrSr)rOr`rrrerr@rrKrr/rarbrk)rrrqrxrsrtrurRrvrwryrzr{r|r-r}rrrrr?rZrrs&&&&&&&&&&&&&&&&&& r2 jobs_uv_runros@C*G6K 5 !C ..%%2  '+FyQ   C JJ}SWW5#**(($//yyFszz/E/EFF ghlgmno#**$$c** $SYY^^$4AcffX=cde YY^^$AcffX. ( 1WX_W``rst %gY.KLM!#s+r4z,Create and manage scheduled Jobs on the Hub. scheduledz>hf jobs scheduled run "0 0 * * *" python:3.12 python script.pyc"V^8dQhR\R\R\R\R\R\ R\ R\R \R \R \R \R \R\R\R\RR/#)r+schedulerqrrsuspend concurrencyrsrtrurRrvrwrxryr{r-r}r.N) ScheduleArgr~r SuspendOptConcurrencyOptrrrrrrrrrrr )r1s"r2r3r3s'Y'Y'Y 'Y'Y 'Y  'Y  'Y'Y 'Y 'Y'Y!'Y 'Y'Y 'Y'Y !'Y" #'Yr4c<\WY4p\Wj4p\VR7pVPVVVVVVV\V4\ VVVR7V V V VR7 p\ P !RVPR7\ P!RVP R24R#) zSchedule a Job.rr) rqrrrrrrsrtrr>rxryr{r-Scheduled Job createdr\Use `hf jobs scheduled inspect ` to view its details.N) r#r"create_scheduled_jobrrSr)rOr`rK)rrqrrrrrsrtrurRrvrwrxryr{r-r}rrr? scheduled_jobs&&&&&&&&&&&&&&&& r2 scheduled_runrs0C*G6K 5 !C,,  '+FyQ-MJJ&=+;+;<HH.}/?/?.@@V WXr4zhf jobs scheduled lscV^8dQhR\\\RRRR73,R\R\R\\ \ ,R ,\R R R R73,R R /#)r+r r r z1Show all scheduled Jobs (default hides suspended)rTr-r}r Nrrz>Filter output based on conditions provided (format: key=value)r.)rrr'rr r@r/)r1s"r2r3r3sOmOm    D   OmOm Om  S D  Q   Om& 'Omr4c 8\VR7pVPVR7p.pT;'g.FpRV9dgVPR^4wrVPR4'd Rp VRR#pMRp VP VP 4WP 434Kp\ P!RV R24K .p VFp V P;'gR p V'g V 'dK+V PP;'gR pV PP;'g.pV'dR PV4MR pR V PR VR\V 4RV/p\VV4'gKV P V 4K .pV EF\p\!V4pVP#R4;'g/pVP#R4;'g/pVP#R4pVP#R4;'g.pVP#R4;'gR VR&V'dR PV4MR VR&V'd8VP#R4'd!VR,R,P%RR 4MR VR&VP#R4'd!VR,R,P%RR 4MR VR&VP#R4;'gR VR&VP V4EK_ \ P&!V.R$OR R7V'g:V'd2RPRV44p\ P(!RV 24V'dGV^,R ,p\ P*!RV R 24\ P*!R!V R"24R#R#)%zList scheduled Jobsrrr!rNz Ignoring invalid filter format 'z'. Use key=value format.FrrDr`rqrrrjob_specrelast_jobrratrrlast_runnext_job_run_atnext_runr r"c36"TFwrq1 V V 2xK R#5irr)rr&or's& r2rscheduled_ps../sDGq#aS Gr(z#No scheduled jobs matched filters: rz(` to view details about a scheduled job.zUse `hf jobs scheduled trigger z)` to trigger a scheduled job immediately.)r`rrrrrrr)r"list_scheduled_jobsr9endswithrNrr)r)rrrrrrr`r/rr(rr-r.rcrK)r r-r}r r?scheduled_jobsrfrrop filtered_jobsrrimage_or_spacer8 command_strpropsr/sjr2r status_dictrr9 first_item_ids&&&& r2 scheduled_psrs, 5 !C,,y,AN*,G \\r\ !8aJC||C  #2h NNCIIK[[]; < KK:1#=UV WM' ''005w &//<<EE$$,,22'*chhsm }''.)SQX\[dfqrw// ]+(#%E!"%88J'--2hhx(..B ??:.ll9%++&ll>:CCe]+.#((3-EYDLQYQ]Q]^bQcQc8D>#.66sC@inZEP__UfEgEgK) *3 / 7 7S Amr Z((9-66Y TII _ WiiDGDD  6{mDE a  2=/Aijk 2=/Ajkl r4zhf jobs scheduled inspect cV^8dQhR\\\,\RR73,R\R\ RR/#)r+scheduled_job_idsz>Scheduled Job IDs to inspect (or 'namespace/scheduled_job_id')rTr-r}r.NrU)r1s"r2r3r38sTWW  S Q  WW W Wr4c(.pVF!p\WA4wrAVPV4K# Tp\VR7pVUu.uFpVPWaR7NK pp\P !VUu.uFp\ V4NK up4R#uupiuupi)z:Display detailed information on one or more scheduled Jobsrscheduled_job_idr-N)r<rNr"inspect_scheduled_jobr)r.r() rr-r}rr,r?rrrs &&& r2scheduled_inspectr7sJ#8K&!$# 5 !C!2 1  !!3C!Y 1IInUn]!-0nUV Vs B -Bdeletezhf jobs scheduled delete c@V^8dQhR\R\R\RR/#r+rr-r}r.NScheduledJobIdArgrr )r1s"r2r3r3Q0 = =' = =  = =r4c\W4wr\VR7pVPWR7\P!RVR7R#)zDelete a scheduled Job.rrzScheduled Job deletedr\N)r<r"delete_scheduled_jobr)rOrr-r}r?s&&& r2scheduled_deleterP?#??O"[ 5 !C.>TJJ&+;c@V^8dQhR\R\R\RR/#rr)r1s"r2r3r3^6 Q Q' Q Q  Q Qr4c\W4wr\VR7pVPWR7\P!RVR7\P !RV R24R#)z Suspend (pause) a scheduled Job.rrzScheduled Job suspendedr\zUse `hf jobs scheduled resume z` to resume it.N)r<r"suspend_scheduled_jobr)rOrKrs&&& r2scheduled_suspendr]sW#??O"[ 5 !C/?UJJ(-=>HH-.>-? OPr4resumezhf jobs scheduled resume c@V^8dQhR\R\R\RR/#rr)r1s"r2r3r3lrr4c\W4wr\VR7pVPWR7\P!RVR7R#)z!Resume (unpause) a scheduled Job.rrzScheduled Job resumedr\N)r<r"resume_scheduled_jobr)rOrs&&& r2scheduled_resumerkrr4triggerzhf jobs scheduled trigger c@V^8dQhR\R\R\RR/#rr)r1s"r2r3r3yrr4c,\W4wr\VR7pVPWR7p\P!RVP VP R7\P!RVPP RVP R24R#) zJTrigger a scheduled Job to run immediately (does not change the schedule).rrzScheduled Job triggeredrrr6z` to stream logs.N) r<r"trigger_scheduled_jobr)rOr`rrKrarb)rr-r}r?rZs&&& r2scheduled_triggerrxst#??O"[ 5 !C # #5E # [CJJ(SVVAHH$SYY^^$4AcffX=N OPr4z>hf jobs scheduled labels --label env=prod --label team=mlz%hf jobs scheduled labels --clearc V^8dQhR\R\R\\\ RRR73,R\ R\ R R /#) r+rrurprqz)Remove all labels from the scheduled job.rTr-r}r.N)rrrrr'rr )r1s"r2r3r3sV66'6 6 T6)2]^^ _6 6  6  6r4c8V'gV'g \R4hV'dV'd \R4h\W4wr\V4;'g/p\VR7pVP WVR7p\ P !RVPR7R#)z?Update labels on a scheduled Job. Replaces all existing labels.rsrtr)rrr-rur\N)rr<rr"update_scheduled_job_labelsr)rOr`)rrurpr-r}rr?rs&&&&& r2scheduled_labelsrs hii  p  #??O"[ u % + +F 5 !C33)I4MJJM$4$45r4z)Schedule UV scripts on HF infrastructure.z.hf jobs scheduled uv run "0 0 * * *" script.pyzrxryr{r-rr\rrN) r#r"create_scheduled_uv_jobrrSr)rOr`rK)rrrrrrqrxrsrtrurRrvrwryr{r-r}rrrrr?rZs&&&&&&&&&&&&&&&&&&& r2scheduled_uv_runrs<C*G6K 5 !C % %%%2  '+FyQ! & C$JJ&3662HH.svvh6L MNr4cV^8dQhR\\,R,R\\\3,R,/#)r+rNr.)r@r/r)r1s"r2r3r3s0d3i$.4S>D3Hr4cvV'gR#/pVF&pRV9dVPR^4MVR3wr4WAV&K( V#)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 provided. Nrr^)r9)r labels_map label_varrrs& r2rrsH !#J 03y0@Y__S!,yRTo 3 r4cV^8dQhR\\\\,,,R\\,R\/#)r+rrr.)r@r/r)r1s"r2r3r3s2DcCi)DI#r4c L\.VOVN5!Uu.uFp\RV44NK pp\\P!4P\ V4^ ,4p\ V4\ V4,V8dVP\V44pW5;;,^,uu&\ V4\ V4,V8:gKpV\ V4, \ V4, W5,,W5&KR\ V4,P!V!p.pVPVP!V!4TPVP!VUu.uF pRV,NK up!4VF~p \W4U U u.uFEwr\ \V 44V 8d\V 4RV ^, R,M \V 4NKG p p p VPVP!V !4K RPV4#uupiuupiuup p i)zy Inspired by: - stackoverflow.com/a/8356620/593036 - stackoverflow.com/questions/9535954/printing-lists-as-tabular-data c3J"TFp\\V44xK R#5ir)rr/)rxs& r2r_tabulate..s/3ac#a&kk3s!#z{{:{}}} -Nz...r) rmaxshutilget_terminal_sizecolumnsrsumindexr1rNr/r) rrcol col_widthsterminal_widthcol_to_minimize row_formatlineswrr col_widthrow_format_argss && r2rrs 9$**3z?;#)# w<#j/ )^ ;*83z?*JSQX\*Y\f\w*wJ 's7|+33Z@J E LL""G,- LL""j$AjS1WWj$ABC!$C 4 4 033q6{Y/FCF?Y] #e +CPQF R 4    Z&&89  99U #P%B sH&H A H rcV^8dQhR\\,R\R\\,3,R\RR/#)r+queuefunc.kwargsr.N)rrrrr)r1s"r2r3r3s<U1XXc8A;>N5OY]bfr4cFV!R/VBFpVPV4K R#)Nr)put)rrrrOs&&& r2_write_generator_to_queuers.. &!r4c V^8dQhR\PPR\R\\ ,3,R\ \,R\\ ,/#)r+rr.rr.)rrrrrrr@r)r1s"r2r3r3sR    ) ) 3 # $d  a[ r4c #"\4pVUu.uFq@P\W1V34NK ppVPRR7xKuupi \dZ\ ;QJdRT4F 'dK RM RM !RT44'dTP 4'dMK}Ki;i \dMi;iTUu.uFqfPRR7NK MuupipR# \PdR#i;i TUu.uFqfPRR7NK Muupipi \Pdii;i;i5i)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 Tg?)ryc3@"TFqP4xK R#5ir)ready)r async_results& r2r%iflatmap_unordered...sN ))++ sFN) r apply_asyncrrrr emptyKeyboardInterruptrrh)rrrrr async_resultsr s&&$ r2rrs0gEfqrfq\b%%&?%vAVWfqMr iii-- s  3N N333N NNNSXS^S^S`S`TaN      @M N  d  + N++    @M N  d  + N++   sE A EB8A B8 EB5'B5;B5B5,B8-D.B84B55B88 CDCD C2C)(C20E2D E D  EED7D/.D76E7E EEEE)z3hf jobs run 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) NNNNNNNNFNFNN)zhf jobs logs zhf jobs logs -f zhf jobs logs --tail 20 z#hf jobs logs -f --tail 100 )FNNN)NNN)z hf jobs lsz hf jobs ls -az&hf jobs ls --status running,schedulingz+hf jobs ls --label env=prod --label team=mlz%hf jobs ls --all --label hf-sandbox=1)FNNdNNN)NN)zhf jobs wait z"hf jobs wait z"hf jobs ls -q | xargs hf jobs wait)NFNN)zhf jobs ssh zhf jobs ssh --dry-runz)hf jobs ssh -i ~/.ssh/id_ed25519)zhf jobs uv run 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.py)NNNNNNNNNNFNFNNNN) NNNNNNNNNNNNN)NNNNNNNNNNNNNNNNN)__doc__r+rmultiprocessing.poolrrcollections.abcrrrpathlibrrrrtypingrr r urllib.parser huggingface_hubr r rrrrhuggingface_hub._jobs_apirhuggingface_hub.errorsrhuggingface_hub.utilsr$huggingface_hub.utils._cache_managerrhuggingface_hub.utils._hf_urisrhuggingface_hub.utils._parsingrr _cli_utilsrrrrrrrr r!r"r#r$r% _frameworkr&r'_outputr(r) get_logger__name__loggerr<rSrr/r~rrr@rrrrrrrrrrrrrrrrrrrrjobs_clirkrrrrrrrrr:rRrXr^rnrwruv_app add_groupr scheduled_apprrrrrrrrscheduled_uv_apprrrrrrrr4r2r)sG .**!TT9+)=7J),   H %.8)X   '  $J =  $J rk*   I   B  $J _     B  $J e  I G   p  I  4  $J   D  4K 0 4K G f   3  I ' I "   -  I .   AI  e     ? @ *  .5 ., .,b  &x&xR '8 '%=$>?A'@A'H  xa xav *(:';<]=]6 )'A&BC9D9* (&?%@A +B +  4 4 n  B),,*  ##L d e6% .5 4, 4,n#QR ={3 .5N O 'Y  'YT'3I2JKOmLOmdy,L+MNWOW0x+J*KL =M =y,L+MN QO Qx+J*KL =M =y,L+MN QO Q H/66.!&QR (t4 .58F-O-Of$6 CL r4