o
    h3*                     @   sT  d dl mZ d dlmZ d dlmZ d dlmZmZ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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DictList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 )JobStagea  
    Enumeration of possible stage of a Job on the Hub.

    Value can be compared to a string:
    ```py
    assert JobStage.COMPLETED == "COMPLETED"
    ```

    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   O/var/www/html/ai/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   r   r   r   r   r   r   r9   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 )Nr1   r$   r2   r%   r&   r'   r(   r)   r*   r<   r=   r>   )r5   r$   r%   r&   r'   r(   r)   r*   r<   r=   r>   r7   r8   r   r   r   r9      s   zJobSpec.__init__r:   )r   r   r   r   r   r   r   r   r   r   intr9   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   r9      s   
zLastJobInfo.__init__r:   )r   r   r   r   r   r   r9   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   )r5   rA   rD   r   r   rE   )r7   r8   rD   rE   r   r   r   r9      s    zScheduledJobStatus.__init__r:   )r   r   r   r   rA   r   r   r9   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   r0   r#   rI   jobSpecrJ   rK   rL   r+   rD   rF   rE   rG   )rD   rE   r,   r    r!   r3   r   )r   r5   r   r#   r;   rI   rJ   rK   rL   rC   r+   r   r,   )r7   r8   r#   r+   r,   r   r   r   r9      s   
" zScheduledJobInfo.__init__r:   )r   r   r   r   r   r   r   r   r;   boolrC   r   r9   r   r   r   r   rH      s   
 (rH   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/r2   r1   )r   	CPU_BASIC
isinstancer   r@   float
startswithlen)	rO   r&   rP   r)   r*   r<   rI   time_units_factorsprefixr   r   r   _create_job_spec  s(   &
r`   N)dataclassesr   r   enumr   typingr   r   r   r   r	   huggingface_hubr
   huggingface_hub._space_apir   huggingface_hub.utils._datetimer   r   r   r   r   r"   r;   rA   rC   rH   r@   r[   r`   r   r   r   r   <module>   sJ   X	C
