@@ -356,13 +356,17 @@ async def upload(auth_claims: dict[str, Any]):
356356 if "file" not in request_files :
357357 return jsonify ({"message" : "No file part in the request" , "status" : "failed" }), 400
358358
359- user_oid = auth_claims ["oid" ]
360- file = request_files .getlist ("file" )[0 ]
361- adls_manager : AdlsBlobManager = current_app .config [CONFIG_USER_BLOB_MANAGER ]
362- file_url = await adls_manager .upload_blob (file , file .filename , user_oid )
363- ingester : UploadUserFileStrategy = current_app .config [CONFIG_INGESTER ]
364- await ingester .add_file (File (content = file , url = file_url , acls = {"oids" : [user_oid ]}), user_oid = user_oid )
365- return jsonify ({"message" : "File uploaded successfully" }), 200
359+ try :
360+ user_oid = auth_claims ["oid" ]
361+ file = request_files .getlist ("file" )[0 ]
362+ adls_manager : AdlsBlobManager = current_app .config [CONFIG_USER_BLOB_MANAGER ]
363+ file_url = await adls_manager .upload_blob (file , file .filename , user_oid )
364+ ingester : UploadUserFileStrategy = current_app .config [CONFIG_INGESTER ]
365+ await ingester .add_file (File (content = file , url = file_url , acls = {"oids" : [user_oid ]}), user_oid = user_oid )
366+ return jsonify ({"message" : "File uploaded successfully" }), 200
367+ except Exception as error :
368+ current_app .logger .error ("Error uploading file: %s" , error )
369+ return jsonify ({"message" : "Error uploading file, check server logs for details." , "status" : "failed" }), 500
366370
367371
368372@bp .post ("/delete_uploaded" )
0 commit comments