File tree Expand file tree Collapse file tree 1 file changed +14
-0
lines changed
unstructured_platform_plugins/etl_uvicorn Expand file tree Collapse file tree 1 file changed +14
-0
lines changed Original file line number Diff line number Diff line change 1212from pydantic import BaseModel , Field , create_model
1313from starlette .responses import RedirectResponse
1414from unstructured_ingest .data_types .file_data import BatchFileData , FileData , file_data_from_dict
15+ from unstructured_ingest .errors import UnstructuredIngestError
1516from uvicorn .config import LOG_LEVELS
1617from uvicorn .importer import import_from_string
1718
@@ -223,6 +224,19 @@ async def _stream_response():
223224 else exc .detail ,
224225 file_data = request_dict .get ("file_data" , None ),
225226 )
227+ except UnstructuredIngestError as exc :
228+ logger .error (
229+ f"UnstructuredIngestError: { exc .error_string } (status_code={ exc .status_code } )" ,
230+ exc_info = True ,
231+ )
232+ return InvokeResponse (
233+ usage = usage ,
234+ message_channels = message_channels ,
235+ filedata_meta = filedata_meta_model .model_validate (filedata_meta .model_dump ()),
236+ status_code = exc .status_code or status .HTTP_500_INTERNAL_SERVER_ERROR ,
237+ status_code_text = exc .error_string ,
238+ file_data = request_dict .get ("file_data" , None ),
239+ )
226240 except Exception as invoke_error :
227241 logger .error (f"failed to invoke plugin: { invoke_error } " , exc_info = True )
228242 return InvokeResponse (
You can’t perform that action at this time.
0 commit comments