(session: SessionDep, record_id: int)
| 1138 | |
| 1139 | |
| 1140 | def finish_record(session: SessionDep, record_id: int) -> ChatRecord: |
| 1141 | if not record_id: |
| 1142 | raise Exception("Record id cannot be None") |
| 1143 | record = get_chat_record_by_id(session, record_id) |
| 1144 | |
| 1145 | record.finish = True |
| 1146 | record.finish_time = datetime.datetime.now() |
| 1147 | |
| 1148 | result = ChatRecord(**record.model_dump()) |
| 1149 | |
| 1150 | stmt = update(ChatRecord).where(and_(ChatRecord.id == record.id)).values( |
| 1151 | finish=record.finish, |
| 1152 | finish_time=record.finish_time |
| 1153 | ) |
| 1154 | |
| 1155 | session.execute(stmt) |
| 1156 | |
| 1157 | session.commit() |
| 1158 | |
| 1159 | return result |
| 1160 | |
| 1161 | |
| 1162 | def get_old_questions(session: SessionDep, datasource: int): |
no test coverage detected