# This file was auto-generated by Fern from our API Definition. import typing from json.decoder import JSONDecodeError from .... import core from ....core.api_error import ApiError from ....core.client_wrapper import AsyncClientWrapper, SyncClientWrapper from ....core.http_response import AsyncHttpResponse, HttpResponse from ....core.jsonable_encoder import jsonable_encoder from ....core.request_options import RequestOptions from ....core.unchecked_base_model import construct_type from ....errors.unprocessable_entity_error import UnprocessableEntityError from ....types.add_knowledge_base_response_model import AddKnowledgeBaseResponseModel from ....types.get_knowledge_base_dependent_agents_response_model import GetKnowledgeBaseDependentAgentsResponseModel from ....types.http_validation_error import HttpValidationError from .types.documents_get_response import DocumentsGetResponse from .types.documents_update_response import DocumentsUpdateResponse # this is used as the default value for optional parameters OMIT = typing.cast(typing.Any, ...) class RawDocumentsClient: def __init__(self, *, client_wrapper: SyncClientWrapper): self._client_wrapper = client_wrapper def create_from_url( self, *, url: str, name: typing.Optional[str] = OMIT, parent_folder_id: typing.Optional[str] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> HttpResponse[AddKnowledgeBaseResponseModel]: """ Create a knowledge base document generated by scraping the given webpage. Parameters ---------- url : str URL to a page of documentation that the agent will have access to in order to interact with users. name : typing.Optional[str] A custom, human-readable name for the document. parent_folder_id : typing.Optional[str] If set, the created document or folder will be placed inside the given folder. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- HttpResponse[AddKnowledgeBaseResponseModel] Successful Response """ _response = self._client_wrapper.httpx_client.request( "v1/convai/knowledge-base/url", method="POST", json={ "url": url, "name": name, "parent_folder_id": parent_folder_id, }, headers={ "content-type": "application/json", }, request_options=request_options, omit=OMIT, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( AddKnowledgeBaseResponseModel, construct_type( type_=AddKnowledgeBaseResponseModel, # type: ignore object_=_response.json(), ), ) return HttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) def create_from_file( self, *, file: core.File, name: typing.Optional[str] = OMIT, parent_folder_id: typing.Optional[str] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> HttpResponse[AddKnowledgeBaseResponseModel]: """ Create a knowledge base document generated form the uploaded file. Parameters ---------- file : core.File See core.File for more documentation name : typing.Optional[str] A custom, human-readable name for the document. parent_folder_id : typing.Optional[str] If set, the created document or folder will be placed inside the given folder. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- HttpResponse[AddKnowledgeBaseResponseModel] Successful Response """ _response = self._client_wrapper.httpx_client.request( "v1/convai/knowledge-base/file", method="POST", data={ "name": name, "parent_folder_id": parent_folder_id, }, files={ "file": file, }, request_options=request_options, omit=OMIT, force_multipart=True, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( AddKnowledgeBaseResponseModel, construct_type( type_=AddKnowledgeBaseResponseModel, # type: ignore object_=_response.json(), ), ) return HttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) def create_from_text( self, *, text: str, name: typing.Optional[str] = OMIT, parent_folder_id: typing.Optional[str] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> HttpResponse[AddKnowledgeBaseResponseModel]: """ Create a knowledge base document containing the provided text. Parameters ---------- text : str Text content to be added to the knowledge base. name : typing.Optional[str] A custom, human-readable name for the document. parent_folder_id : typing.Optional[str] If set, the created document or folder will be placed inside the given folder. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- HttpResponse[AddKnowledgeBaseResponseModel] Successful Response """ _response = self._client_wrapper.httpx_client.request( "v1/convai/knowledge-base/text", method="POST", json={ "text": text, "name": name, "parent_folder_id": parent_folder_id, }, headers={ "content-type": "application/json", }, request_options=request_options, omit=OMIT, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( AddKnowledgeBaseResponseModel, construct_type( type_=AddKnowledgeBaseResponseModel, # type: ignore object_=_response.json(), ), ) return HttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) def get( self, documentation_id: str, *, agent_id: typing.Optional[str] = None, request_options: typing.Optional[RequestOptions] = None, ) -> HttpResponse[DocumentsGetResponse]: """ Get details about a specific documentation making up the agent's knowledge base Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. agent_id : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- HttpResponse[DocumentsGetResponse] Successful Response """ _response = self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}", method="GET", params={ "agent_id": agent_id, }, request_options=request_options, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( DocumentsGetResponse, construct_type( type_=DocumentsGetResponse, # type: ignore object_=_response.json(), ), ) return HttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) def delete( self, documentation_id: str, *, force: typing.Optional[bool] = None, request_options: typing.Optional[RequestOptions] = None, ) -> HttpResponse[typing.Any]: """ Delete a document from the knowledge base Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. force : typing.Optional[bool] If set to true, the document will be deleted regardless of whether it is used by any agents and it will be deleted from the dependent agents. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- HttpResponse[typing.Any] Successful Response """ _response = self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}", method="DELETE", params={ "force": force, }, request_options=request_options, ) try: if _response is None or not _response.text.strip(): return HttpResponse(response=_response, data=None) if 200 <= _response.status_code < 300: _data = typing.cast( typing.Any, construct_type( type_=typing.Any, # type: ignore object_=_response.json(), ), ) return HttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) def update( self, documentation_id: str, *, name: str, request_options: typing.Optional[RequestOptions] = None ) -> HttpResponse[DocumentsUpdateResponse]: """ Update the name of a document Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. name : str A custom, human-readable name for the document. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- HttpResponse[DocumentsUpdateResponse] Successful Response """ _response = self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}", method="PATCH", json={ "name": name, }, headers={ "content-type": "application/json", }, request_options=request_options, omit=OMIT, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( DocumentsUpdateResponse, construct_type( type_=DocumentsUpdateResponse, # type: ignore object_=_response.json(), ), ) return HttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) def get_agents( self, documentation_id: str, *, cursor: typing.Optional[str] = None, page_size: typing.Optional[int] = None, request_options: typing.Optional[RequestOptions] = None, ) -> HttpResponse[GetKnowledgeBaseDependentAgentsResponseModel]: """ Get a list of agents depending on this knowledge base document Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. cursor : typing.Optional[str] Used for fetching next page. Cursor is returned in the response. page_size : typing.Optional[int] How many documents to return at maximum. Can not exceed 100, defaults to 30. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- HttpResponse[GetKnowledgeBaseDependentAgentsResponseModel] Successful Response """ _response = self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}/dependent-agents", method="GET", params={ "cursor": cursor, "page_size": page_size, }, request_options=request_options, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( GetKnowledgeBaseDependentAgentsResponseModel, construct_type( type_=GetKnowledgeBaseDependentAgentsResponseModel, # type: ignore object_=_response.json(), ), ) return HttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) def get_content( self, documentation_id: str, *, request_options: typing.Optional[RequestOptions] = None ) -> HttpResponse[None]: """ Get the entire content of a document from the knowledge base Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- HttpResponse[None] """ _response = self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}/content", method="GET", request_options=request_options, ) try: if 200 <= _response.status_code < 300: return HttpResponse(response=_response, data=None) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) class AsyncRawDocumentsClient: def __init__(self, *, client_wrapper: AsyncClientWrapper): self._client_wrapper = client_wrapper async def create_from_url( self, *, url: str, name: typing.Optional[str] = OMIT, parent_folder_id: typing.Optional[str] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> AsyncHttpResponse[AddKnowledgeBaseResponseModel]: """ Create a knowledge base document generated by scraping the given webpage. Parameters ---------- url : str URL to a page of documentation that the agent will have access to in order to interact with users. name : typing.Optional[str] A custom, human-readable name for the document. parent_folder_id : typing.Optional[str] If set, the created document or folder will be placed inside the given folder. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AsyncHttpResponse[AddKnowledgeBaseResponseModel] Successful Response """ _response = await self._client_wrapper.httpx_client.request( "v1/convai/knowledge-base/url", method="POST", json={ "url": url, "name": name, "parent_folder_id": parent_folder_id, }, headers={ "content-type": "application/json", }, request_options=request_options, omit=OMIT, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( AddKnowledgeBaseResponseModel, construct_type( type_=AddKnowledgeBaseResponseModel, # type: ignore object_=_response.json(), ), ) return AsyncHttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) async def create_from_file( self, *, file: core.File, name: typing.Optional[str] = OMIT, parent_folder_id: typing.Optional[str] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> AsyncHttpResponse[AddKnowledgeBaseResponseModel]: """ Create a knowledge base document generated form the uploaded file. Parameters ---------- file : core.File See core.File for more documentation name : typing.Optional[str] A custom, human-readable name for the document. parent_folder_id : typing.Optional[str] If set, the created document or folder will be placed inside the given folder. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AsyncHttpResponse[AddKnowledgeBaseResponseModel] Successful Response """ _response = await self._client_wrapper.httpx_client.request( "v1/convai/knowledge-base/file", method="POST", data={ "name": name, "parent_folder_id": parent_folder_id, }, files={ "file": file, }, request_options=request_options, omit=OMIT, force_multipart=True, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( AddKnowledgeBaseResponseModel, construct_type( type_=AddKnowledgeBaseResponseModel, # type: ignore object_=_response.json(), ), ) return AsyncHttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) async def create_from_text( self, *, text: str, name: typing.Optional[str] = OMIT, parent_folder_id: typing.Optional[str] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> AsyncHttpResponse[AddKnowledgeBaseResponseModel]: """ Create a knowledge base document containing the provided text. Parameters ---------- text : str Text content to be added to the knowledge base. name : typing.Optional[str] A custom, human-readable name for the document. parent_folder_id : typing.Optional[str] If set, the created document or folder will be placed inside the given folder. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AsyncHttpResponse[AddKnowledgeBaseResponseModel] Successful Response """ _response = await self._client_wrapper.httpx_client.request( "v1/convai/knowledge-base/text", method="POST", json={ "text": text, "name": name, "parent_folder_id": parent_folder_id, }, headers={ "content-type": "application/json", }, request_options=request_options, omit=OMIT, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( AddKnowledgeBaseResponseModel, construct_type( type_=AddKnowledgeBaseResponseModel, # type: ignore object_=_response.json(), ), ) return AsyncHttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) async def get( self, documentation_id: str, *, agent_id: typing.Optional[str] = None, request_options: typing.Optional[RequestOptions] = None, ) -> AsyncHttpResponse[DocumentsGetResponse]: """ Get details about a specific documentation making up the agent's knowledge base Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. agent_id : typing.Optional[str] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AsyncHttpResponse[DocumentsGetResponse] Successful Response """ _response = await self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}", method="GET", params={ "agent_id": agent_id, }, request_options=request_options, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( DocumentsGetResponse, construct_type( type_=DocumentsGetResponse, # type: ignore object_=_response.json(), ), ) return AsyncHttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) async def delete( self, documentation_id: str, *, force: typing.Optional[bool] = None, request_options: typing.Optional[RequestOptions] = None, ) -> AsyncHttpResponse[typing.Any]: """ Delete a document from the knowledge base Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. force : typing.Optional[bool] If set to true, the document will be deleted regardless of whether it is used by any agents and it will be deleted from the dependent agents. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AsyncHttpResponse[typing.Any] Successful Response """ _response = await self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}", method="DELETE", params={ "force": force, }, request_options=request_options, ) try: if _response is None or not _response.text.strip(): return AsyncHttpResponse(response=_response, data=None) if 200 <= _response.status_code < 300: _data = typing.cast( typing.Any, construct_type( type_=typing.Any, # type: ignore object_=_response.json(), ), ) return AsyncHttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) async def update( self, documentation_id: str, *, name: str, request_options: typing.Optional[RequestOptions] = None ) -> AsyncHttpResponse[DocumentsUpdateResponse]: """ Update the name of a document Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. name : str A custom, human-readable name for the document. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AsyncHttpResponse[DocumentsUpdateResponse] Successful Response """ _response = await self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}", method="PATCH", json={ "name": name, }, headers={ "content-type": "application/json", }, request_options=request_options, omit=OMIT, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( DocumentsUpdateResponse, construct_type( type_=DocumentsUpdateResponse, # type: ignore object_=_response.json(), ), ) return AsyncHttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) async def get_agents( self, documentation_id: str, *, cursor: typing.Optional[str] = None, page_size: typing.Optional[int] = None, request_options: typing.Optional[RequestOptions] = None, ) -> AsyncHttpResponse[GetKnowledgeBaseDependentAgentsResponseModel]: """ Get a list of agents depending on this knowledge base document Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. cursor : typing.Optional[str] Used for fetching next page. Cursor is returned in the response. page_size : typing.Optional[int] How many documents to return at maximum. Can not exceed 100, defaults to 30. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AsyncHttpResponse[GetKnowledgeBaseDependentAgentsResponseModel] Successful Response """ _response = await self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}/dependent-agents", method="GET", params={ "cursor": cursor, "page_size": page_size, }, request_options=request_options, ) try: if 200 <= _response.status_code < 300: _data = typing.cast( GetKnowledgeBaseDependentAgentsResponseModel, construct_type( type_=GetKnowledgeBaseDependentAgentsResponseModel, # type: ignore object_=_response.json(), ), ) return AsyncHttpResponse(response=_response, data=_data) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json) async def get_content( self, documentation_id: str, *, request_options: typing.Optional[RequestOptions] = None ) -> AsyncHttpResponse[None]: """ Get the entire content of a document from the knowledge base Parameters ---------- documentation_id : str The id of a document from the knowledge base. This is returned on document addition. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- AsyncHttpResponse[None] """ _response = await self._client_wrapper.httpx_client.request( f"v1/convai/knowledge-base/{jsonable_encoder(documentation_id)}/content", method="GET", request_options=request_options, ) try: if 200 <= _response.status_code < 300: return AsyncHttpResponse(response=_response, data=None) if _response.status_code == 422: raise UnprocessableEntityError( headers=dict(_response.headers), body=typing.cast( HttpValidationError, construct_type( type_=HttpValidationError, # type: ignore object_=_response.json(), ), ), ) _response_json = _response.json() except JSONDecodeError: raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text) raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response_json)