File: //usr/local/lib/python3.10/dist-packages/openai/resources/__pycache__/files.cpython-310.pyc
o
���g�u � @ s| d dl mZ d dlZd dlZd dlmZmZ d dlmZ d dlZddl m
Z
ddl m Z m
Z
mZ ddlmZmZmZmZmZmZ dd lmZmZmZmZ dd
lm Z dd l m Z m Z dd l m!Z!m"Z"m#Z#m$Z$m%Z%m&Z& dd
l'm(Z(m)Z) ddl*m+Z+m,Z, ddl-m.Z. ddl/m0Z0 ddl1m Z ddgZ2G dd� de �Z3G dd� de �Z4G dd� d�Z5G dd� d�Z6G dd� d�Z7G d d � d �Z8dS ) � )� annotationsN)�Mapping�cast)�Literal� )�_legacy_response)� FilePurpose�file_list_params�file_create_params)� NOT_GIVEN�Body�Query�Headers�NotGiven� FileTypes)�
extract_files�maybe_transform�deepcopy_minimal�async_maybe_transform)�cached_property)�SyncAPIResource�AsyncAPIResource)�StreamedBinaryAPIResponse� AsyncStreamedBinaryAPIResponse� to_streamed_response_wrapper�"async_to_streamed_response_wrapper�#to_custom_streamed_response_wrapper�)async_to_custom_streamed_response_wrapper)�SyncCursorPage�AsyncCursorPage)�AsyncPaginator�make_request_options)�
FileObject)� FileDeleted)r �Files�
AsyncFilesc @ �� e Zd Zed9dd��Zed:dd��Zddded �d;dd�Zddded �d<dd �Zeeeeddded �d=d%d&�Z ddded �d>d(d)�Z
ddded �d?d+d,�Z e �
d-�ddded �d@d.d/��Zd0d1d2�dAd7d8�ZdS )Br$ �return�FilesWithRawResponsec C � t | �S �a
This property can be used as a prefix for any HTTP method call to return
the raw response object instead of the parsed content.
For more information, see https://www.github.com/openai/openai-python#accessing-raw-response-data-eg-headers
)r( ��self� r- �A/usr/local/lib/python3.10/dist-packages/openai/resources/files.py�with_raw_response) � zFiles.with_raw_response�FilesWithStreamingResponsec C r) �z�
An alternative to `.with_raw_response` that doesn't eagerly read the response body.
For more information, see https://www.github.com/openai/openai-python#with_streaming_response
)r1 r+ r- r- r. �with_streaming_response3 � z Files.with_streaming_responseN��
extra_headers� extra_query�
extra_body�timeout�filer �purposer r6 �Headers | Noner7 � Query | Noner8 � Body | Noner9 �'float | httpx.Timeout | None | NotGivenr" c
C sd t ||d��}tttttf |�dggd�}ddi|p i �}| jdt|tj �|t
||||d�t d�S ) � Upload a file that can be used across various endpoints.
Individual files can be
up to 512 MB, and the size of all files uploaded by one organization can be up
to 100 GB.
The Assistants API supports files up to 2 million tokens and of specific file
types. See the
[Assistants Tools guide](https://platform.openai.com/docs/assistants/tools) for
details.
The Fine-tuning API only supports `.jsonl` files. The input also has certain
required formats for fine-tuning
[chat](https://platform.openai.com/docs/api-reference/fine-tuning/chat-input) or
[completions](https://platform.openai.com/docs/api-reference/fine-tuning/completions-input)
models.
The Batch API only supports `.jsonl` files up to 200 MB in size. The input also
has a specific required
[format](https://platform.openai.com/docs/api-reference/batch/request-input).
Please [contact us](https://help.openai.com/) if you need to increase these
storage limits.
Args:
file: The File object (not file name) to be uploaded.
purpose: The intended purpose of the uploaded file.
Use "assistants" for
[Assistants](https://platform.openai.com/docs/api-reference/assistants) and
[Message](https://platform.openai.com/docs/api-reference/messages) files,
"vision" for Assistants image file inputs, "batch" for
[Batch API](https://platform.openai.com/docs/guides/batch), and "fine-tune" for
[Fine-tuning](https://platform.openai.com/docs/api-reference/fine-tuning).
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
�r: r; r: ��paths� Content-Type�multipart/form-data�/filesr5 ��body�files�options�cast_to) r r r r �str�object�_postr r
�FileCreateParamsr! r" � r, r: r; r6 r7 r8 r9 rH rI r- r- r. �create< s 8��
��z Files.create�file_idrL c C �4 |s t d|����| jd|� �t||||d�td�S )�^
Returns information about a specific file.
Args:
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
�6Expected a non-empty value for `file_id` but received �/files/r5 �rJ rK ��
ValueError�_getr! r" �r, rR r6 r7 r8 r9 r- r- r. �retrieve� � ��zFiles.retrieve��after�limit�orderr; r6 r7 r8 r9 r_ �str | NotGivenr` �int | NotGivenra �!Literal['asc', 'desc'] | NotGiven�SyncCursorPage[FileObject]c C �6 | j dtt t||||t||||d�tj�d�td�S �a� Returns a list of files.
Args:
after: A cursor for use in pagination.
`after` is an object ID that defines your place
in the list. For instance, if you make a list request and receive 100 objects,
ending with obj_foo, your subsequent call can include after=obj_foo in order to
fetch the next page of the list.
limit: A limit on the number of objects to be returned. Limit can range between 1 and
10,000, and the default is 10,000.
order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending
order and `desc` for descending order.
purpose: Only return files with the given purpose.
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
rF )r_ r` ra r; )r6 r7 r8 r9 �query)�pagerJ �model)�
_get_api_listr r" r! r r �FileListParams� r, r_ r` ra r; r6 r7 r8 r9 r- r- r. �list� �& (����z
Files.listr# c C rS )�B
Delete a file.
Args:
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
rU rV r5 rW �rY �_deleter! r# r[ r- r- r. �delete� r] z Files.delete�+_legacy_response.HttpxBinaryResponseContentc C sH |s t d|����ddi|pi �}| jd|� d�t||||d�tjd�S )�_
Returns the contents of the specified file.
Args:
extra_headers: Send extra headers
extra_query: Add additional query parameters to the request
extra_body: Add additional JSON properties to the request
timeout: Override the client-level default timeout for this request, in seconds
rU �Accept�application/binaryrV �/contentr5 rW �rY rZ r! r �HttpxBinaryResponseContentr[ r- r- r. �content s
��z
Files.content�.The `.content()` method should be used insteadc C s6 |s t d|����| jd|� d�t||||d�td�S )ru rU rV rx r5 rW �rY rZ r! rL r[ r- r- r. �retrieve_content* s
��zFiles.retrieve_content� @� ��
poll_interval�max_wait_seconds�idr� �floatr� c C sl h d�}t � � }| �|�}|j|vr4| �|� | �|�}t � � | |kr/td|� d|� d���|j|vs|S )�EWaits for the given file to be processed, default timeout is 30 mins.> �error�deleted� processed� Giving up on waiting for file � to finish processing after � seconds.��timer\ �status�_sleep� RuntimeError�r, r� r� r� �TERMINAL_STATES�startr: r- r- r. �wait_for_processingL s
�
� zFiles.wait_for_processing)r' r( )r' r1 �r: r r; r r6 r< r7 r= r8 r> r9 r? r' r" � rR rL r6 r< r7 r= r8 r> r9 r? r' r" )r_ rb r` rc ra rd r; rb r6 r< r7 r= r8 r> r9 r? r' re � rR rL r6 r< r7 r= r8 r> r9 r? r' r# � rR rL r6 r< r7 r= r8 r> r9 r? r' rt � rR rL r6 r< r7 r= r8 r> r9 r? r' rL �r� rL r� r� r� r� r' r" ��__name__�
__module__� __qualname__r r/ r3 r rQ r\ rn rs r{ �typing_extensions�
deprecatedr~ r� r- r- r- r. r$ ( �V �S�$�C�'�"�%�c @ r& )Br% r' �AsyncFilesWithRawResponsec C r) r* )r� r+ r- r- r. r/ e r0 z AsyncFiles.with_raw_response� AsyncFilesWithStreamingResponsec C r) r2 )r� r+ r- r- r. r3 o r4 z"AsyncFiles.with_streaming_responseNr5 r: r r; r r6 r< r7 r= r8 r> r9 r? r" c
� sr �t ||d��}tttttf |�dggd�}ddi|p i �}| jdt|tj �I dH |t
||||d�t d �I dH S )
r@ rA r: rB rD rE rF Nr5 rG ) r r r r rL rM rN r r
rO r! r" rP r- r- r. rQ x s" �8�� � �zAsyncFiles.createrR rL c � �< �|s
t d|����| jd|� �t||||d�td�I dH S )rT rU rV r5 rW NrX r[ r- r- r. r\ � � �� �zAsyncFiles.retriever^ r_ rb r` rc ra rd �7AsyncPaginator[FileObject, AsyncCursorPage[FileObject]]c C rf rg )rk r r" r! r r rl rm r- r- r. rn � ro zAsyncFiles.listr# c � r� )rp rU rV r5 rW Nrq r[ r- r- r. rs # r� zAsyncFiles.deletert c � sP �|s
t d|����ddi|pi �}| jd|� d�t||||d�tjd�I dH S ) ru rU rv rw rV rx r5 rW Nry r[ r- r- r. r{ D s �
� �zAsyncFiles.contentr| c � s> �|s
t d|����| jd|� d�t||||d�td�I dH S )ru rU rV rx r5 rW Nr} r[ r- r- r. r~ f s �
� �zAsyncFiles.retrieve_contentr r� r� r� r� r� r� c � s� �h d�}t � � }| �|�I dH }|j|vr>| �|�I dH | �|�I dH }t � � | |kr9td|� d|� d���|j|vs|S )r� > r� r� r� Nr� r� r� r� r� r- r- r. r� � s �
�
� z AsyncFiles.wait_for_processing)r' r� )r' r� r� r� )r_ rb r` rc ra rd r; rb r6 r< r7 r= r8 r> r9 r? r' r� r� r� r� r� r� r- r- r- r. r% d r� c @ � e Zd Zddd�ZdS ) r( rI r$ r' �Nonec C �^ || _ t�|j�| _t�|j�| _t�|j�| _t�|j�| _t�|j�| _t�|j�| _d S �N) �_filesr �to_raw_response_wrapperrQ r\ rn rs r{ r~ �r, rI r- r- r. �__init__� �( �������z FilesWithRawResponse.__init__N�rI r$ r' r� �r� r� r� r� r- r- r- r. r( � � r( c @ r� ) r� rI r% r' r� c C r� r� ) r� r � async_to_raw_response_wrapperrQ r\ rn rs r{ r~ r� r- r- r. r� � r� z"AsyncFilesWithRawResponse.__init__N�rI r% r' r� r� r- r- r- r. r� � r� r� c @ r� ) r1 rI r$ r' r� c C �T || _ t|j�| _t|j�| _t|j�| _t|j�| _t|jt�| _t|j �| _ d S r� )
r� r rQ r\ rn rs r r{ r r~ r� r- r- r. r� � �* �������z#FilesWithStreamingResponse.__init__Nr� r� r- r- r- r. r1 � r� r1 c @ r� ) r� rI r% r' r� c C r� r� )
r� r rQ r\ rn rs r r{ r r~ r� r- r- r. r� � r� z(AsyncFilesWithStreamingResponse.__init__Nr� r� r- r- r- r. r� � r� r� )9�
__future__r r� r� �typingr r r �httpx� r �typesr r r
�_typesr r r
r r r �_utilsr r r r �_compatr � _resourcer r � _responser r r r r r �
paginationr r � _base_clientr r! �types.file_objectr" �types.file_deletedr# �types.file_purpose�__all__r$ r% r( r� r1 r� r- r- r- r. �<module> s: > >