U &Jj?@sDddlmZddlmZmZddlmZddlZddlm Z ddl m Z m Z m Z mZmZmZmZddlmZmZdd lmZdd lmZmZdd lmZmZmZmZdd lm Z dd l!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddgZ)GdddeZ*GdddeZ+GdddZ,GdddZ-GdddZ.GdddZ/dS)) annotations)DictOptional)LiteralN)batch_create_params)BodyOmitQueryHeadersNotGivenomit not_given)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)make_request_options)BatchListResponse)BatchCancelResponse)BatchCreateResponse)BatchRetrieveResponseBatches AsyncBatchesc @seZdZeddddZeddddZeddded d d d d d ddddd ddZdddedd d dddddddZ dddedd dddddddZ dddedd d ddddddd Z dS)!rBatchesWithRawResponsereturncCst|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/groq/groq-python#accessing-raw-response-data-eg-headers )rselfr%w/var/www/api.dyntland.com/public_html/python_social_comments/venv/lib/python3.8/site-packages/groq/resources/batches.pywith_raw_responseszBatches.with_raw_responseBatchesWithStreamingResponsecCst|Sz An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/groq/groq-python#with_streaming_response )r(r#r%r%r&with_streaming_response)szBatches.with_streaming_responseNmetadata extra_headers extra_query extra_bodytimeoutstrLiteral['/v1/chat/completions']Optional[Dict[str, str]] | OmitHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenr completion_windowendpoint input_file_idr,r-r.r/r0r!c Cs0|jdt||||dtjt||||dtdS)_ Creates and executes a batch from an uploaded file of requests. [Learn more](/docs/batch). Args: completion_window: The time frame within which the batch should be processed. Durations from `24h` to `7d` are supported. endpoint: The endpoint to be used for all requests in the batch. Currently `/v1/chat/completions` is supported. input_file_id: The ID of an uploaded file that contains requests for the new batch. See [upload file](/docs/api-reference#files-upload) for how to upload a file. Your input file must be formatted as a [JSONL file](/docs/batch), and must be uploaded with the purpose `batch`. The file 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 /openai/v1/batchesr9r:r;r,r-r.r/r0bodyoptionscast_to)_postrrBatchCreateParamsrr r$r9r:r;r,r-r.r/r0r%r%r&create2s$* zBatches.creater?rbatch_idr-r.r/r0r!cCs4|std||jd|t||||dtdS)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 /openai/v1/batches/r?rBrC ValueError_getrrr$rIr-r.r/r0r%r%r&retrievemszBatches.retrieverr-r.r/r0r!cCs|jdt||||dtdS)!List your organization's batches.r=r?rMrPrrr$r-r.r/r0r%r%r&lists z Batches.listrcCs6|std||jd|dt||||dtdS)D Cancels 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 rKrL/cancelr?rMrOrDrrrQr%r%r&cancels zBatches.cancel __name__ __module__ __qualname__rr'r*r rrGrRrWr[r%r%r%r&rs2 "A&c @seZdZeddddZeddddZeddded d d d d d ddddd ddZdddedd d dddddddZ dddedd dddddddZ dddedd d ddddddd Z dS)!rAsyncBatchesWithRawResponser cCst|Sr")r`r#r%r%r&r'szAsyncBatches.with_raw_response!AsyncBatchesWithStreamingResponsecCst|Sr))rar#r%r%r&r*sz$AsyncBatches.with_streaming_responseNr+r1r2r3r4r5r6r7rr8c s<|jdt||||dtjIdHt||||dtdIdHS)r<r=r>Nr?r@)rDrrrErrrFr%r%r&rGs$* zAsyncBatches.creater?rrHcs:|std||jd|t||||dtdIdHS)rJrKrLr?rMNrNrQr%r%r&rRszAsyncBatches.retrieverrScs"|jdt||||dtdIdHS)rTr=r?rMNrUrVr%r%r&rW3s zAsyncBatches.listrcs<|std||jd|dt||||dtdIdHS)rXrKrLrYr?rMNrZrQr%r%r&r[Fs zAsyncBatches.cancelr\r%r%r%r&rs2 "A&c@seZdZdddddZdS)rrNonebatchesr!cCs:||_t|j|_t|j|_t|j|_t|j|_dSN)_batchesrrGrRrWr[r$rdr%r%r&__init__iszBatchesWithRawResponse.__init__Nr]r^r_rhr%r%r%r&rhsrc@seZdZdddddZdS)r`rrbrccCs:||_t|j|_t|j|_t|j|_t|j|_dSre)rfrrGrRrWr[rgr%r%r&rh{sz$AsyncBatchesWithRawResponse.__init__Nrir%r%r%r&r`zsr`c@seZdZdddddZdS)r(rrbrccCs:||_t|j|_t|j|_t|j|_t|j|_dSre)rfrrGrRrWr[rgr%r%r&rhsz%BatchesWithStreamingResponse.__init__Nrir%r%r%r&r(sr(c@seZdZdddddZdS)rarrbrccCs:||_t|j|_t|j|_t|j|_t|j|_dSre)rfrrGrRrWr[rgr%r%r&rhsz*AsyncBatchesWithStreamingResponse.__init__Nrir%r%r%r&rasra)0 __future__rtypingrrtyping_extensionsrZhttpxtypesr_typesrr r r r r rZ_utilsrrZ_compatrZ _resourcerr _responserrrrZ _base_clientrZtypes.batch_list_responserZtypes.batch_cancel_responserZtypes.batch_create_responserZtypes.batch_retrieve_responser__all__rrrr`r(rar%r%r%r&s.   $      &&