OYhfHXddlmZddlmZmZddlmZddlZddlm Z ddl m Z m Z ddl mZmZmZmZmZdd lmZmZdd lmZdd lmZmZdd lmZmZdd lmZm Z ddl!m"Z"ddl#m$Z$m%Z%ddgZ&GddeZ'GddeZ(GddZ)GddZ*GddZ+GddZ,y)) annotations)DictOptional)LiteralN)_legacy_response)batch_list_paramsbatch_create_params) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)Batch)AsyncPaginatormake_request_optionsBatches AsyncBatchesceZdZed dZed dZeddded d dZddded ddZeeddded dd Z ddded dd Z y)rct|SN)BatchesWithRawResponseselfs W/var/www/feuerwehr-webapp/venv/lib/python3.12/site-packages/openai/resources/batches.pywith_raw_responsezBatches.with_raw_responses %d++ct|Sr )BatchesWithStreamingResponser"s r$with_streaming_responsezBatches.with_streaming_response#s +D11r&Nmetadata extra_headers extra_query extra_bodytimeoutc |jdt||||dtjt ||||t S) Creates and executes a batch from an uploaded file of requests Args: completion_window: The time frame within which the batch should be processed. Currently only `24h` is supported. endpoint: The endpoint to be used for all requests in the batch. Currently `/v1/chat/completions`, `/v1/embeddings`, and `/v1/completions` are supported. Note that `/v1/embeddings` batches are also restricted to a maximum of 50,000 embedding inputs across all requests in the batch. input_file_id: The ID of an uploaded file that contains requests for the new batch. See [upload file](https://platform.openai.com/docs/api-reference/files/create) for how to upload a file. Your input file must be formatted as a [JSONL file](https://platform.openai.com/docs/api-reference/batch/request-input), and must be uploaded with the purpose `batch`. The file can contain up to 50,000 requests, and can be up to 100 MB in size. metadata: Optional custom metadata for the batch. 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 /batchescompletion_windowendpoint input_file_idr+r,r-r.r/bodyoptionscast_to)_postrr BatchCreateParamsrr r#r4r5r6r+r,r-r.r/s r$createzBatches.create's\\zz  ): (%2 (  $55)+Q[el  r&r7c r|std||jd|t||||tS)F Retrieves a batch. 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 7Expected a non-empty value for `batch_id` but received /batches/r7r:r; ValueError_getrrr#batch_idr,r-r.r/s r$retrievezBatches.retrievefsT.VW_Vbcd dyyz "(+Q[el   r&afterlimitr,r-r.r/c|jdttt||||t ||dt j tSa,List your organization's batches. 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 100, and the default is 20. 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 r2)rLrM)r,r-r.r/query)pager:model) _get_api_listrrrrr BatchListParamsr#rLrMr,r-r.r/s r$listz Batches.lists_B!! &(+'%%!&!&&55  !"  r&c t|std||jd|dt||||tS) Cancels an in-progress batch. The batch will be in status `cancelling` for up to 10 minutes, before changing to `cancelled`, where it will have partial results (if any) available in the output 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 rBrC/cancelr7rDrFr<rrrHs r$cancelzBatches.cancelsV4VW_Vbcd dzzz )(+Q[el   r&)returnr!)r\r(r4zLiteral['24h']r5zDLiteral['/v1/chat/completions', '/v1/embeddings', '/v1/completions']r6strr+z#Optional[Dict[str, str]] | NotGivenr,Headers | Noner- Query | Noner. Body | Noner/'float | httpx.Timeout | None | NotGivenr\r rIr^r,r_r-r`r.rar/rbr\r)rLstr | NotGivenrMint | NotGivenr,r_r-r`r.rar/rbr\zSyncCursorPage[Batch] __name__ __module__ __qualname__rr%r)r r?rJrVr[r&r$rrs,,229B)-$("&;D= *= W =  = 6 = &= "=  = 9=  = J)-$("&;D  &  "   9   H!* ))-$("&;D2 2  2 &2 "2  2 92  2 t)-$("&;D" " & " ""  " 9"  " r&ceZdZed dZed dZeddded d dZddded ddZeeddded dd Z ddded dd Z y)rct|Sr )AsyncBatchesWithRawResponser"s r$r%zAsyncBatches.with_raw_responses *400r&ct|Sr )!AsyncBatchesWithStreamingResponser"s r$r)z$AsyncBatches.with_streaming_responses 066r&Nr*c K|jdt||||dtjd{t ||||t d{S7$7w)r1r2r3Nr7r8)r<rr r=rrr>s r$r?zAsyncBatches.createsu\ZZ ,): (%2 (  $55)+Q[el     s!/AA AAAAr7c K|std||jd|t||||td{S7w)rArBrCr7rDNrErHs r$rJzAsyncBatches.retrieve(sb.VW_Vbcd dYYz "(+Q[el     s> NN  )@@     %<< LL  '>> NN  r&Nryrr\Nonergrhrirzrjr&r$r!r! r&r!ceZdZddZy)rmc2||_tj|j|_tj|j|_tj|j |_tj|j |_yr )rvrasync_to_raw_response_wrapperr?rJrVr[rxs r$rzz$AsyncBatchesWithRawResponse.__init__su &DD NN  )FF     %BB LL  'DD NN  r&Nryrr\r|r}rjr&r$rmrmr~r&rmceZdZddZy)r(c||_t|j|_t|j|_t|j|_t|j |_yr )rvrr?rJrVr[rxs r$rzz%BatchesWithStreamingResponse.__init__s] 2 NN  5     1 LL  3 NN  r&Nr{r}rjr&r$r(r(r~r&r(ceZdZddZy)roc||_t|j|_t|j|_t|j|_t|j |_yr )rvrr?rJrVr[rxs r$rzz*AsyncBatchesWithStreamingResponse.__init__s] 8 NN  ;     7 LL  9 NN  r&Nrr}rjr&r$roror~r&ro)- __future__rtypingrrtyping_extensionsrhttpxrtypesr r _typesr r r rr_utilsrr_compatr _resourcerr _responserr paginationrr types.batchr _base_clientrr__all__rrr!rmr(rorjr&r$rs#!% :>>&9X8 n % o D # D  $  $  $  r&