diff --git a/api/schedule/user_profile_generate_task.py b/api/schedule/user_profile_generate_task.py index 8dde420437..200ad01acc 100644 --- a/api/schedule/user_profile_generate_task.py +++ b/api/schedule/user_profile_generate_task.py @@ -2,13 +2,12 @@ import logging import time from datetime import datetime -from sqlalchemy import asc, func, or_ - import app from configs import dify_config from core.app.entities.app_invoke_entities import InvokeFrom from models.model import App, EndUser, Message, db from services.app_generate_service import AppGenerateService +from sqlalchemy import asc, func, or_ logger = logging.getLogger(__name__) logger.setLevel(logging.INFO) @@ -236,6 +235,12 @@ def process_user_health_summary(user: EndUser, new_messages: str): result = response["data"]["outputs"]["result"] + if result is None: + logger.warning( + f"Health summary generation failed with None result for user {user.id}" + ) + return + # preprocess result in case of ```json xxxx``` if result.startswith("```json") or result.endswith("```"): result = result.strip("```json").strip("```")