|
@@ -316,17 +316,15 @@ class DatasetService:
|
|
|
return read_permission_list
|
|
|
|
|
|
@staticmethod
|
|
|
- def update_dataset_edit_auth(dataset_id, edit_auth):
|
|
|
+ def update_dataset_edit_auth(dataset_id, edit_auth, user):
|
|
|
dataset = DatasetService.get_dataset(dataset_id)
|
|
|
if not dataset:
|
|
|
raise ValueError("Dataset not found")
|
|
|
|
|
|
if dataset.edit_auth != edit_auth:
|
|
|
- filtered_data["updated_by"] = user.id
|
|
|
- filtered_data["updated_at"] = datetime.datetime.now()
|
|
|
- filtered_data["edit_auth"] = edit_auth
|
|
|
-
|
|
|
- dataset.query.filter_by(id=dataset_id).update(filtered_data)
|
|
|
+ dataset.query.filter_by(id=dataset_id).update(
|
|
|
+ {"edit_auth": edit_auth, "updated_by": user.id, "updated_at": datetime.datetime.now()}
|
|
|
+ )
|
|
|
db.session.commit()
|
|
|
# if action:
|
|
|
# deal_dataset_vector_index_task.delay(dataset_id, action)
|