(self, cid)
| 388 | return await self.get_conversation_by_id(cid) |
| 389 | |
| 390 | async def delete_conversation(self, cid) -> None: |
| 391 | async with self.get_db() as session: |
| 392 | session: AsyncSession |
| 393 | async with session.begin(): |
| 394 | await session.execute( |
| 395 | delete(ConversationV2).where( |
| 396 | col(ConversationV2.conversation_id) == cid, |
| 397 | ), |
| 398 | ) |
| 399 | |
| 400 | async def delete_conversations_by_user_id(self, user_id: str) -> None: |
| 401 | async with self.get_db() as session: |