(self, thread_id: str)
| 215 | await self.execute_sql(query=query, parameters=parameters) |
| 216 | |
| 217 | async def delete_thread(self, thread_id: str): |
| 218 | if self.show_logger: |
| 219 | logger.info(f"SQLAlchemy: delete_thread, thread_id={thread_id}") |
| 220 | # Delete feedbacks/elements/steps/thread |
| 221 | feedbacks_query = """DELETE FROM feedbacks WHERE "forId" IN (SELECT "id" FROM steps WHERE "threadId" = :id)""" |
| 222 | elements_query = """DELETE FROM elements WHERE "threadId" = :id""" |
| 223 | steps_query = """DELETE FROM steps WHERE "threadId" = :id""" |
| 224 | thread_query = """DELETE FROM threads WHERE "id" = :id""" |
| 225 | parameters = {"id": thread_id} |
| 226 | await self.execute_sql(query=feedbacks_query, parameters=parameters) |
| 227 | await self.execute_sql(query=elements_query, parameters=parameters) |
| 228 | await self.execute_sql(query=steps_query, parameters=parameters) |
| 229 | await self.execute_sql(query=thread_query, parameters=parameters) |
| 230 | |
| 231 | async def list_threads( |
| 232 | self, pagination: Pagination, filters: ThreadFilter |
nothing calls this directly
no test coverage detected