diff --git a/api/core/app/apps/advanced_chat/app_generator.py b/api/core/app/apps/advanced_chat/app_generator.py index 2aa12ef157..c1a4c429af 100644 --- a/api/core/app/apps/advanced_chat/app_generator.py +++ b/api/core/app/apps/advanced_chat/app_generator.py @@ -523,7 +523,8 @@ class AdvancedChatAppGenerator(MessageBasedAppGenerator): with Session(bind=db.engine, expire_on_commit=False) as session: workflow = _refresh_model(session=session, model=workflow) message = _refresh_model(session=session, model=message) - assert message is not None + if message is None: + raise RuntimeError("Failed to refresh Message; _refresh_model returned None.") # workflow_ = session.get(Workflow, workflow.id) # assert workflow_ is not None # workflow = workflow_ diff --git a/api/core/app/apps/chat/app_generator.py b/api/core/app/apps/chat/app_generator.py index fb326bd6ba..fdc6179344 100644 --- a/api/core/app/apps/chat/app_generator.py +++ b/api/core/app/apps/chat/app_generator.py @@ -166,8 +166,8 @@ class ChatAppGenerator(MessageBasedAppGenerator): # init generate records (conversation, message) = self._init_generate_records(application_generate_entity, conversation) - assert conversation is not None - assert message is not None + if conversation is None or message is None: + raise RuntimeError("_init_generate_records() returned None for conversation or message") generated_conversation_id = str(conversation.id) generated_message_id = str(message.id) diff --git a/api/core/app/apps/completion/app_generator.py b/api/core/app/apps/completion/app_generator.py index 24292dfe16..e9f0587002 100644 --- a/api/core/app/apps/completion/app_generator.py +++ b/api/core/app/apps/completion/app_generator.py @@ -149,8 +149,11 @@ class CompletionAppGenerator(MessageBasedAppGenerator): # init generate records (conversation, message) = self._init_generate_records(application_generate_entity) - assert conversation is not None - assert message is not None + if conversation is None or message is None: + raise RuntimeError( + "_init_generate_records() returned None for conversation or message, " + "which is required to proceed with generation." + ) # init queue manager queue_manager = MessageBasedAppQueueManager(