$%h1aUddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl Z ddl Z ddl mZddlmZmZmZmZmZmZdd lmZmZmZdd lmZmZmZmZmZdd l m!Z!m"Z"dd l#m$Z$dd l%m&Z&m'Z'ddl(m)Z)m*Z*ddl+m,Z,ddl-m.Z.ddl/mZddgZ0dZ1ejde3Z4de5d<Gdde&Z6Gdde'Z7GddZ8GddZ9GddZ:Gdd Z;y)!) annotationsN)Listoverload)Path)_legacy_response)Parts AsyncPartsPartsWithRawResponseAsyncPartsWithRawResponsePartsWithStreamingResponseAsyncPartsWithStreamingResponse) FilePurposeupload_create_paramsupload_complete_params) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)make_request_options)Upload)rUploads AsyncUploadsizlogging.LoggerlogcveZdZeddZeddZeddZedded ddZ eded ddZ ddded  dd Z ddded  dd Z ddded  dd Z eddded ddZ y)r!c,t|jSN)r _clientselfs ^/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/openai/resources/uploads/uploads.pypartsz Uploads.parts,sT\\""ct|Sa 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 )UploadsWithRawResponser(s r*with_raw_responsezUploads.with_raw_response0s&d++r,ct|Sz 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 )UploadsWithStreamingResponser(s r*with_streaming_responsezUploads.with_streaming_response:s,D11r,Nbytes part_sizemd5cyzESplits a file into multiple 64MB parts and uploads them sequentially.Nr)file mime_typepurposer6r7r8s r*upload_file_chunkedzUploads.upload_file_chunkedCr,r7r8cyzPSplits an in-memory file into multiple 64MB parts and uploads them sequentially.Nr;r)r=filenamer6r>r?r7r8s r*r@zUploads.upload_file_chunkedPrAr,rFr6r7r8c>t|tjr| td|Ptdt|ts t |}|s |j }||j j}|j||||}g} |t}t|tjrtj|} ntj|} | j|} | snn|jj|j| } t j#d| j|j| j%| j |j+|j| |S#t&$r| j)wxYw)"Splits the given file into multiple parts and uploads them sequentially. ```py from pathlib import Path client.uploads.upload_file( file=Path("my-paper.pdf"), mime_type="pdf", purpose="assistants", ) ``` 9The `filename` argument must be given for in-memory files6The `bytes` argument must be given for in-memory filesr6rFr>r? upload_iddataUploaded part %s for upload %srNpart_idsr8) isinstancebuiltinsr6 TypeErrorrnamestatst_sizecreateDEFAULT_PART_SIZEioBytesIOFileIOreadr+idr#infoappend Exceptionclosecomplete) r)r=r>r?rFr6r7r8uploadrRbufrOparts r*r@zUploads.upload_file_chunked^sh. dHNN + [\\} XYYdD)Dz99} ++  !  )I dHNN +*,**T*:C))D/C xx *zz((6994(H9477FIIN(}}vyy8}MM   IIK  s BFF extra_headers extra_query extra_bodytimeoutc |jdt||||dtjt ||||t S) Creates an intermediate [Upload](https://platform.openai.com/docs/api-reference/uploads/object) object that you can add [Parts](https://platform.openai.com/docs/api-reference/uploads/part-object) to. Currently, an Upload can accept at most 8 GB in total and expires after an hour after you create it. Once you complete the Upload, we will create a [File](https://platform.openai.com/docs/api-reference/files/object) object that contains all the parts you uploaded. This File is usable in the rest of our platform as a regular File object. For certain `purpose` values, the correct `mime_type` must be specified. Please refer to documentation for the [supported MIME types for your use case](https://platform.openai.com/docs/assistants/tools/file-search#supported-files). For guidance on the proper filename extensions for each purpose, please follow the documentation on [creating a File](https://platform.openai.com/docs/api-reference/files/create). Args: bytes: The number of bytes in the file you are uploading. filename: The name of the file to upload. mime_type: The MIME type of the file. This must fall within the supported MIME types for your file purpose. See the supported MIME types for assistants and vision. purpose: The intended purpose of the uploaded file. See the [documentation on File purposes](https://platform.openai.com/docs/api-reference/files/create#files-create-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 /uploadsrLrhbodyoptionscast_to)_postrrUploadCreateParamsrr r)r6rFr>r?rirjrkrls r*rYzUploads.creates\tzz  " (!*&  %77)+Q[el  r,c t|std||jd|dt||||tS){Cancels the Upload. No Parts may be added after an Upload is cancelled. 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 8Expected a non-empty value for `upload_id` but received /uploads//cancelrhrrrs ValueErrorrtrr r)rNrirjrkrls r*cancelzUploads.cancelsV0WXaWdef fzz {' *(+Q[el   r,r8rirjrkrlc |std||jd|dt||dtjt ||||t S)L Completes the [Upload](https://platform.openai.com/docs/api-reference/uploads/object). Within the returned Upload object, there is a nested [File](https://platform.openai.com/docs/api-reference/files/object) object that is ready to use in the rest of the platform. You can specify the order of the Parts by passing in an ordered list of the Part IDs. The number of bytes uploaded upon completion must match the number of bytes initially specified when creating the Upload object. No Parts may be added after an Upload is completed. Args: part_ids: The ordered list of Part IDs. md5: The optional md5 checksum for the file contents to verify if the bytes uploaded matches what you expect. 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 ryrz /completerRr8rhrp)r~rtrrUploadCompleteParamsrr r)rNrRr8rirjrkrls r*rdzUploads.completeswTWXaWdef fzz {) , (';; )+Q[el  r,)returnr )rr/)rr3r=zos.PathLike[str]r>strr?rr6 int | Noner7rr8str | NotGivenrr r=r6rFrr6intr>rr?rr7rr8rrr r=zos.PathLike[str] | bytesr>rr?rrFz str | Noner6rr7rr8rrr r6rrFrr>rr?rriHeaders | Nonerj Query | Nonerk Body | Nonerl'float | httpx.Timeout | None | NotGivenrr rNrrirrjrrkrrlrrr rNrrRz List[str]r8rrirrjrrkrrlrrr __name__ __module__ __qualname__rr+r0r4rrr@rYrrdr;r,r*r!r!+s##,,22! $' T T T  T  T T T  T T!%' _ _ _  _  _ _ _ _  _ _& $ $'FN'FN FN  FN  FNFNFNFN FNb)-$("&;DI I  I  I  I &I "I  I 9I  I b)-$("&;D    &  "     9     N()-$("&;D9 9  9  9 &9 "9  9 99  9 r,cveZdZeddZeddZeddZedded ddZ eded ddZ ddded  dd Z ddded  dd Z ddded  dd Z eddded ddZ y)r"c,t|jSr&)r r'r(s r*r+zAsyncUploads.partsPs$,,''r,ct|Sr.)AsyncUploadsWithRawResponser(s r*r0zAsyncUploads.with_raw_responseTs+400r,ct|Sr2)!AsyncUploadsWithStreamingResponser(s r*r4z$AsyncUploads.with_streaming_response^s166r,Nr5c Kywr:r;r<s r*r@z AsyncUploads.upload_file_chunkedgrBc KywrDr;rEs r*r@z AsyncUploads.upload_file_chunkedtrrrGcpKt|tjr| td|ntdt|tj st j |}|s |j }|$|jd{}|j}|j||||d{} g} |t}t|tj r|jdd{} | 4d{ | j|d{} | snv|jj| j| d{} tj!d| j| j| j#| jdddd{nt%j&|} |j|} | snv|jj| j| d{} tj!d| j| j| j#| j |j-| j| |d{S7777z7c747#1d{7swYLxYw7#t($r|j+wxYw7Mw) rINrJrKrLrbrMrPrQ)rSrTr6rUanyiorrVrWrXrYrZopenr^r+r_r#r`rar[r\rbrcrd)r)r=r>r?rFr6r7r8rWrerRfdrOrgrfs r*r@z AsyncUploads.upload_file_chunkedsU. dHNN + [\\} XYYdEJJ/zz$'99}!YY[( {{ #  !  )I dEJJ 'yy&B - -!#!33D!%!2!2VYYT!2!RRDHH=tww ROODGG, - - -**T"C 88I.D!%!2!2VYYT!2!RRDHH=tww ROODGG,]]VYYs]SSSY) ' -3 S - - - -(S   TsBJ6 I+ (J62I.3I?I71I?I:A I? J6I=J69?J8J9A J"J6&J4'J6.J61J64J67I?:I?=J6?JJ J J6JJ11J6rhc K|jdt||||dtjd{t ||||t d{S7$7w)rnrorLNrhrp)rtrrrurr rvs r*rYzAsyncUploads.createsutZZ ," (!*&  %77)+Q[el     s!/AA AAAAc K|std||jd|dt||||td{S7w)rxryrzr{rhr|Nr}rs r*rzAsyncUploads.cancel sd0WXaWdef fZZ {' *(+Q[el      s=AAArc K|std||jd|dt||dtjd{t ||||t d{S7$7w)rryrzrrNrhrp)r~rtrrrrr rs r*rdzAsyncUploads.completeBsTWXaWdef fZZ {) ,, (';; )+Q[el     s$AA,A( A,#A*$A,*A,)rr )rr)rrrrrrrrrr;r,r*r"r"Os((1177! $' T T T  T  T T T  T T!%' _ _ _  _  _ _ _ _  _ _& $ $'QT'QT QT  QT  QTQTQTQT QTx)-$("&;DI I  I  I  I &I "I  I 9I  I b)-$("&;D    &  "     9     N()-$("&;D9 9  9  9 &9 "9  9 99  9 r,c&eZdZddZeddZy)r/c||_tj|j|_tj|j|_tj|j |_yr&)_uploadsrto_raw_response_wrapperrYrrdr)uploadss r*__init__zUploadsWithRawResponse.__init__sZ &>> NN  '>> NN  )@@     r,c@t|jjSr&)r rr+r(s r*r+zUploadsWithRawResponse.partss#DMM$7$788r,Nrr!rNone)rr rrrrrr+r;r,r*r/r/~s  99r,r/c&eZdZddZeddZy)rc||_tj|j|_tj|j|_tj|j |_yr&)rrasync_to_raw_response_wrapperrYrrdrs r*rz$AsyncUploadsWithRawResponse.__init__sZ &DD NN  'DD NN  )FF     r,c@t|jjSr&)r rr+r(s r*r+z!AsyncUploadsWithRawResponse.partss()<)<==r,Nrr"rr)rr rr;r,r*rrs  >>r,rc&eZdZddZeddZy)r3c||_t|j|_t|j|_t|j|_yr&)rrrYrrdrs r*rz%UploadsWithStreamingResponse.__init__sH 2 NN  3 NN  5     r,c@t|jjSr&)rrr+r(s r*r+z"UploadsWithStreamingResponse.partss)$--*=*=>>r,Nr)rrrr;r,r*r3r3s  ??r,r3c&eZdZddZeddZy)rc||_t|j|_t|j|_t|j|_yr&)rrrYrrdrs r*rz*AsyncUploadsWithStreamingResponse.__init__sH 8 NN  9 NN  ;     r,c@t|jjSr&)rrr+r(s r*r+z'AsyncUploadsWithStreamingResponse.partss.t}}/B/BCCr,Nr)rrrr;r,r*rrs  DDr,r)< __future__rr[osloggingrTtypingrrpathlibrrhttpxrr+r r r r rrtypesrrr_typesrrrrr_utilsrr_compatr _resourcerr _responserr _base_clientr types.uploadr types.file_purpose__all__rZ getLoggerrr#__annotations__r!r"r/rr3rr;r,r*rs# ! ON??<&:Y0"- n %%'g''1^1a oa H l #l ^ 99&>>&??&DDr,