@@ -220,19 +220,26 @@ async def match_conversations(
220220 conversations = []
221221 for chat_id , sorted_convers in sorted_convers .items ():
222222 questions_answers = []
223+ first_partial_conversation = None
223224 for partial_conversation in sorted_convers :
224- partial_conversation .question_answer .question .message = parse_question_answer (
225- partial_conversation .question_answer .question .message )
226- questions_answers .append (partial_conversation .question_answer )
227- conversations .append (
228- Conversation (
229- question_answers = questions_answers ,
230- provider = partial_conversation .provider ,
231- type = partial_conversation .type ,
232- chat_id = chat_id ,
233- conversation_timestamp = sorted_convers [0 ].request_timestamp ,
225+ # check if we have an answer, otherwise do not add it
226+ if partial_conversation .question_answer .answer is not None :
227+ first_partial_conversation = partial_conversation
228+ partial_conversation .question_answer .question .message = parse_question_answer (
229+ partial_conversation .question_answer .question .message )
230+ questions_answers .append (partial_conversation .question_answer )
231+
232+ # only add conversation if we have some answers
233+ if len (questions_answers ) > 0 and first_partial_conversation is not None :
234+ conversations .append (
235+ Conversation (
236+ question_answers = questions_answers ,
237+ provider = first_partial_conversation .provider ,
238+ type = first_partial_conversation .type ,
239+ chat_id = chat_id ,
240+ conversation_timestamp = sorted_convers [0 ].request_timestamp ,
241+ )
234242 )
235- )
236243
237244 return conversations
238245
0 commit comments