wip(summary-flows) Add additional filter

ChildMindInstitute · Jun 7, 2024 · c5b4b7b · c5b4b7b
1 parent 9a6138f
commit c5b4b7b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/apps/answers/crud/answers.py b/src/apps/answers/crud/answers.py
@@ -500,7 +500,10 @@ async def get_submitted_flows_with_last_date(
             subquery = subquery.where(AnswerSchema.target_subject_id == target_subject_id)
 
         query: Query = select(AnswerSchema.flow_history_id, func.max(AnswerSchema.created_at))
-        query = query.where(AnswerSchema.submit_id.in_(subquery))
+        query = query.where(
+            AnswerSchema.submit_id.in_(subquery),
+            AnswerSchema.is_flow_completed.is_(True),
+        )
         query = query.group_by(AnswerSchema.flow_history_id)
         query = query.order_by(AnswerSchema.flow_history_id)
         db_result = await self._execute(query)