(session: SessionDep, trans: Trans, user: CurrentUser, ds: CoreDatasource)
| 98 | |
| 99 | |
| 100 | def update_ds(session: SessionDep, trans: Trans, user: CurrentUser, ds: CoreDatasource): |
| 101 | ds.id = int(ds.id) |
| 102 | check_name(session, trans, user, ds) |
| 103 | # status = check_status(session, trans, ds) |
| 104 | ds.status = "Success" |
| 105 | record = session.exec(select(CoreDatasource).where(CoreDatasource.id == ds.id)).first() |
| 106 | update_data = ds.model_dump(exclude_unset=True) |
| 107 | for field, value in update_data.items(): |
| 108 | setattr(record, field, value) |
| 109 | session.add(record) |
| 110 | session.commit() |
| 111 | |
| 112 | run_save_ds_embeddings([ds.id]) |
| 113 | return ds |
| 114 | |
| 115 | |
| 116 | def update_ds_recommended_config(session: SessionDep, datasource_id: int, recommended_config: int): |
no test coverage detected