o
    viA5                     @   sp  d dl mZ d dlmZ d dlmZ d dlmZmZmZ d dl	m
Z
 d dlmZ d dlmZ G dd	 d	eeZeG d
d dZeG dd dZeG dd dZeG dd dZeG dd dZeG dd dZeG dd dZeG dd dZeG dd dZdedee deeeef  deeeef  d ee d!eeeeef  d"eeef fd#d$Zd%S )&    )	dataclass)datetime)Enum)AnyOptionalUnion)	constants)SpaceHardware)parse_datetimec                   @   s$   e Zd ZdZdZdZdZdZdZdS )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).
    	COMPLETEDCANCELEDERRORDELETEDRUNNINGN)	__name__
__module____qualname____doc__r   r   r   r   r    r   r   X/home/air/biblejyuku/back/venv/lib/python3.10/site-packages/huggingface_hub/_jobs_api.pyr      s    r   c                   @   s"   e Zd ZU eed< ee ed< dS )	JobStatusstagemessageN)r   r   r   r   __annotations__r   strr   r   r   r   r   -   s   
 r   c                   @   s&   e Zd ZU eed< eed< eed< dS )JobOwneridnametypeN)r   r   r   r   r   r   r   r   r   r   3   s   
 r   c                   @   s   e Zd ZU dZeed< ee ed< ee ed< ee ed< eee  ed< eee  ed< ee	ee
f  ed< ee	ee
f  ed	< ee ed
< eed< eed< eed< eed< dddZdS )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_imagespace_idcommand	argumentsenvironmentsecretsflavorstatusownerendpointurlreturnNc                 K   s  |d | _ |dp|d}|rt|nd | _|dp!|d| _|dp,|d| _|di }t|d |d	 |d
 d| _|d| _|d| _	|d| _
|d| _|d| _|di }t|d |dd| _|dtj| _| j d| jj d| j  | _d S )Nr   	createdAtr!   dockerImager"   spaceIdr#   r*   r   r   r   r   r   r$   r%   r&   r'   r(   r)   r   r   )r   r   r+   z/jobs//)r   getr
   r!   r"   r#   r   r*   r$   r%   r&   r'   r(   r   r)   r   ENDPOINTr+   r   r,   )selfkwargsr!   r*   r)   r   r   r   __init__~   s    
"zJobInfo.__init__r-   N)r   r   r   r   r   r   r   r   listdictr   r	   r   r   r7   r   r   r   r   r    :   s    
 2r    c                   @   s   e Zd ZU ee ed< ee ed< eee  ed< eee  ed< eeeef  ed< eeeef  ed< ee	 ed< ee
 ed< eee  ed	< ee ed
< dddZdS )JobSpecr"   r#   r$   r%   r&   r'   r(   timeouttagsarchr-   Nc                 K   s   | dp	| d| _| dp| d| _| d| _| d| _| d| _| d| _| d	| _| d
| _| d| _	| d| _
d S )Nr/   r"   r0   r#   r$   r%   r&   r'   r(   r<   r=   r>   )r3   r"   r#   r$   r%   r&   r'   r(   r<   r=   r>   r5   r6   r   r   r   r7      s   zJobSpec.__init__r8   )r   r   r   r   r   r   r9   r:   r   r	   intr7   r   r   r   r   r;      s   
 r;   c                   @   s(   e Zd ZU eed< eed< dddZdS )LastJobInfor   atr-   Nc                 K   s   |d | _ t|d | _d S )Nr   rB   )r   r
   rB   r?   r   r   r   r7      s   
zLastJobInfo.__init__r8   )r   r   r   r   r   r   r7   r   r   r   r   rA      s   
 rA   c                   @   s0   e Zd ZU ee ed< ee ed< dddZdS )ScheduledJobStatuslast_jobnext_job_run_atr-   Nc                 K   s`   | dp	| d}|rtdi |nd | _| dp| d}|r+tt|| _d S d | _d S )NlastJobrD   nextJobRunAtrE   r   )r3   rA   rD   r
   r   rE   )r5   r6   rD   rE   r   r   r   r7      s    zScheduledJobStatus.__init__r8   )r   r   r   r   rA   r   r   r7   r   r   r   r   rC      s   
 rC   c                   @   sl   e Zd ZU dZeed< ee ed< eed< ee ed< ee	 ed< ee	 ed< e
ed< eed	< d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_specschedulesuspendconcurrencyr)   r*   r-   Nc                 K   s   |d | _ |dp|d}|rt|nd | _tdi |dp%|di | _|d| _|d| _|d| _|d	i }t	|d
pK|d|dpT|dd| _
|di }t|d |d |d d| _d S )Nr   r.   r!   rI   jobSpecrJ   rK   rL   r)   rD   rF   rE   rG   )rD   rE   r*   r   r   r1   r   )r   r3   r
   r!   r;   rI   rJ   rK   rL   rC   r)   r   r*   )r5   r6   r!   r)   r*   r   r   r   r7      s   
" zScheduledJobInfo.__init__r8   )r   r   r   r   r   r   r   r   r;   boolrC   r   r7   r   r   r   r   rH      s   
 (rH   c                   @   sD   e Zd ZU dZeed< eed< eed< eed< eed< dd	d
ZdS )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"`.
    r   modelquantityvrammanufacturerr-   Nc                 K   s6   |d | _ |d | _|d | _|d | _|d | _d S )Nr   rP   rQ   rR   rS   )r   rP   rQ   rR   rS   r?   r   r   r   r7     s
   



zJobAccelerator.__init__r8   )r   r   r   r   r   r   r7   r   r   r   r   rO     s   
 rO   c                   @   s`   e Zd ZU dZeed< eed< eed< eed< ee ed< eed< e	ed< eed	< dddZ
dS )JobHardwarea  
    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"`.
        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]
    JobHardware(name='cpu-basic', pretty_name='CPU Basic', cpu='2 vCPU', ram='16 GB', accelerator=None, unit_cost_micro_usd=167, unit_cost_usd=0.000167, unit_label='minute')
    >>> hardware_list[0].name
    'cpu-basic'
    ```
    r   pretty_namecpuramacceleratorunit_cost_micro_usdunit_cost_usd
unit_labelr-   Nc                 K   sl   |d | _ |d | _|d | _|d | _|d}|r"td	i |nd | _|d | _|d | _|d | _	d S )
Nr   
prettyNamerV   rW   rX   unitCostMicroUSDunitCostUSD	unitLabelr   )
r   rU   rV   rW   r3   rO   rX   rY   rZ   r[   )r5   r6   rX   r   r   r   r7   S  s   






zJobHardware.__init__r8   )r   r   r   r   r   r   r   rO   r@   floatr7   r   r   r   r   rT   '  s   
 !rT   imager$   envr'   r(   r<   r-   c           	      C   s   |g |pi |p	t jd}|r||d< |r?ddddd}t|tr9|d |v r9tt|d d ||d   |d	< nt||d	< d
D ]}| |rU| t|d  |d<  |S qA| |d< |S )N)r$   r%   r&   r(   r'      <   i  iQ )smhdtimeoutSeconds)zhttps://huggingface.co/spaces/zhttps://hf.co/spaces/zhuggingface.co/spaces/zhf.co/spaces/r0   r/   )r	   	CPU_BASIC
isinstancer   r@   r`   
startswithlen)	ra   r$   rb   r'   r(   r<   rI   time_units_factorsprefixr   r   r   _create_job_spec_  s(   &
rq   N)dataclassesr   r   enumr   typingr   r   r   huggingface_hubr   huggingface_hub._space_apir	   huggingface_hub.utils._datetimer
   r   r   r   r   r    r;   rA   rC   rH   rO   rT   r9   r:   r@   r`   rq   r   r   r   r   <module>   sR   X	C7
