wi*PddlmZddlmZddlmZddlmZmZmZm Z m Z ddl m Z ddl mZddlmZGdd eeZeGd d ZeGd d ZeGddZeGddZeGddZeGddZeGddZdedeede eeefde eeefde ede e eeefdeeeffdZd S)!) dataclass)datetime)Enum)AnyDictListOptionalUnion) constants) SpaceHardware)parse_datetimec&eZdZdZdZdZdZdZdZdS)JobStageah 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`, `RUNNING`. Taken from https://github.com/huggingface/moon-landing/blob/main/server/job_types/JobInfo.ts#L61 (private url). COMPLETEDCANCELEDERRORDELETEDRUNNINGN) __name__ __module__ __qualname____doc__rrrrrq/var/www/development/aibuddy-work/election-extract/venv/lib/python3.11/site-packages/huggingface_hub/_jobs_api.pyrrs3  IH EGGGGrrc0eZdZUeed<eeed<dS) JobStatusstagemessageN)rrrr__annotations__r strrrrrr-s+ OOO c]rrc.eZdZUeed<eed<eed<dS)JobOwneridnametypeN)rrrr!r rrrr#r#3s+ GGG III IIIIIrr#c6eZdZUdZeed<eeed<eeed<eeed<eeeed<eeeed<ee ee fed<ee ee fed <ee ed <e ed <e ed <eed <eed<ddZdS)JobInfoa& Contains information about a Job. Args: id (`str`): Job ID. created_at (`datetime` or `None`): When the Job was created. docker_image (`str` or `None`): The Docker image from Docker Hub used for the Job. Can be None if space_id is present instead. space_id (`str` or `None`): The Docker image from Hugging Face Spaces used for the Job. Can be None if docker_image is present instead. command (`List[str]` or `None`): Command of the Job, e.g. `["python", "-c", "print('hello world')"]` arguments (`List[str]` or `None`): Arguments passed to the command environment (`Dict[str]` or `None`): Environment variables of the Job as a dictionary. secrets (`Dict[str]` or `None`): Secret environment variables of the Job (encrypted). flavor (`str` or `None`): Flavor for the hardware, as in Hugging Face Spaces. See [`SpaceHardware`] for possible values. E.g. `"cpu-basic"`. status: (`JobStatus` or `None`): Status of the Job, e.g. `JobStatus(stage="RUNNING", message=None)` See [`JobStage`] for possible stage values. owner: (`JobOwner` or `None`): Owner of the Job, e.g. `JobOwner(id="5e9ecfc04957053f60648a3e", name="lhoestq", type="user")` Example: ```python >>> 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), docker_image='python:3.12', space_id=None, command=['python', '-c', "print('Hello from the cloud!')"], arguments=[], environment={}, secrets={}, flavor='cpu-basic', status=JobStatus(stage='RUNNING', message=None), owner=JobOwner(id='5e9ecfc04957053f60648a3e', name='lhoestq', type='user'), 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$ created_at docker_imagespace_idcommand arguments environmentsecretsflavorstatusownerendpointurlreturnNc |d|_|dp|d}|rt|nd|_|dp|d|_|dp|d|_|di}t |d|d |d  |_|d |_|d |_ |d|_ |d|_ |d|_ |di}t|d|d|_|dtj|_|jd|jjd|j|_dS)Nr$ createdAtr) dockerImager*spaceIdr+r2r%r&r$r%r&r,r-r.r/r0r1rr)rrr3z/jobs//)r$getr r)r*r+r#r2r,r-r.r/r0rr1r ENDPOINTr3r%r4)selfkwargsr)r2r1s r__init__zJobInfo.__init__~s,ZZ ,,H <0H0H 8BL.444"JJ}55SN9S9S 9--GJ1G1G  7B''t5=uV}UUU zz),, K00!::m44zz),, jj** Hb))fWovzz)?T?TUUU  :y/ABB mFF4:?FFTWFFrr5N)rrrrr!r r rrrrr rr#r@rrrr(r(:s 00d GGG""""3-sm d3i    S """"$sCx.)))) d38n %%%% ] ####  OOOMMM HHHGGGGGGrr(c8eZdZUeeed<eeed<eeeed<eeeed<eeeefed<eeeefed<ee ed<ee ed<eeeed <eeed <dd Z d S)JobSpecr*r+r,r-r.r/r0timeouttagsarchr5Nc b|dp|d|_|dp|d|_|d|_|d|_|d|_|d|_|d |_|d |_|d |_ |d |_ dS) Nr8r*r9r+r,r-r.r/r0rDrErF) r<r*r+r,r-r.r/r0rDrErFr>r?s rr@zJobSpec.__init__s"JJ}55SN9S9S 9--GJ1G1G zz),, K00!::m44zz),, jj** zz),, JJv&& JJv&& rrA) rrrr r!r rrrr intr@rrrrCrCs3-sm d3i    S """"$sCx.)))) d38n %%%% ] #### c] 49  3- ' ' ' ' ' 'rrCc,eZdZUeed<eed<ddZdS) LastJobInfor$atr5Nc T|d|_t|d|_dS)Nr$rL)r$r rLrHs rr@zLastJobInfo.__init__s$, ..rrA)rrrr!r rr@rrrrKrKs< GGGLLL//////rrKcDeZdZUeeed<eeed<ddZdS)ScheduledJobStatuslast_jobnext_job_run_atr5Nc "|dp|d}|r tdi|nd|_|dp|d}|rtt |nd|_dS)NlastJobrP nextJobRunAtrQr)r<rKrPr r!rQ)r>r?rPrQs rr@zScheduledJobStatus.__init__s::i((BFJJz,B,B3;E //h///  **^44U CT8U8UGV`~c/.B.BCCC\`rrA)rrrr rKr rr@rrrrOrOsR{####h''''aaaaaarrOceZdZUdZeed<eeed<eed<eeed<ee ed<ee ed<e ed<e ed <d d Z d S)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$r)job_specschedulesuspend concurrencyr1r2r5Nc *|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$r7r)rWjobSpecrXrYrZr1rPrSrQrT)rPrQr2r%r&r:r) r$r<r r)rCrWrXrYrZrOr1r#r2)r>r?r)r1r2s rr@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 rrA) rrrrr!r r rrCboolrOr#r@rrrrVrVs&&P GGG""""sm d^$  OOOVVVVVVrrVimager,envr/r0rDr5c|g|pi|p tjd}|r||d<|roddddd}t|trA|d|vr7t t |dd||dz|d <nt ||d <d D]3}||r|t|d|d <n4||d <|S) N)r,r-r.r0r/<iiQ)smhdtimeoutSeconds)zhttps://huggingface.co/spaces/zhttps://hf.co/spaces/zhuggingface.co/spaces/z hf.co/spaces/r9r8)r CPU_BASIC isinstancer!rIfloat startswithlen) r^r,r_r/r0rDrWtime_units_factorsprefixs r_create_job_specrpsyb3M3   H&%6#$2DyII gs # # 6 7I(I(I),U73B3<-@-@CUV]^`VaCb-b)c)cH% & &),WH% & ( (   F # # "'F "6HY  E #( OrN) dataclassesrrenumrtypingrrrr r huggingface_hubr huggingface_hub._space_apir huggingface_hub.utils._datetimer r!rrr#r(rCrKrOrVrIrkrprrrrws"!!!!!33333333333333%%%%%%444444::::::sD(       UGUGUGUGUGUGUG UGp ''''''' '2 /////// / aaaaaaa a @V@V@V@V@V@V@V @VF& &#Y& $sCx. ! & d38n % & ] # &eCO, -& #s(^&&&&&&r