| documents = DocumentService.get_document_by_dataset_id(dataset_id_str) | documents = DocumentService.get_document_by_dataset_id(dataset_id_str) | ||||
| for document in documents: | for document in documents: | ||||
| document_indexing_sync_task.delay(dataset_id_str, document.id) | document_indexing_sync_task.delay(dataset_id_str, document.id) | ||||
| return 200 | |||||
| return {"result": "success"}, 200 | |||||
| class DataSourceNotionDocumentSyncApi(Resource): | class DataSourceNotionDocumentSyncApi(Resource): | ||||
| if document is None: | if document is None: | ||||
| raise NotFound("Document not found.") | raise NotFound("Document not found.") | ||||
| document_indexing_sync_task.delay(dataset_id_str, document_id_str) | document_indexing_sync_task.delay(dataset_id_str, document_id_str) | ||||
| return 200 | |||||
| return {"result": "success"}, 200 | |||||
| api.add_resource(DataSourceApi, "/data-source/integrates", "/data-source/integrates/<uuid:binding_id>/<string:action>") | api.add_resource(DataSourceApi, "/data-source/integrates", "/data-source/integrates/<uuid:binding_id>/<string:action>") |
| MetadataService.enable_built_in_field(dataset) | MetadataService.enable_built_in_field(dataset) | ||||
| elif action == "disable": | elif action == "disable": | ||||
| MetadataService.disable_built_in_field(dataset) | MetadataService.disable_built_in_field(dataset) | ||||
| return 200 | |||||
| return {"result": "success"}, 200 | |||||
| class DocumentMetadataEditApi(Resource): | class DocumentMetadataEditApi(Resource): | ||||
| MetadataService.update_documents_metadata(dataset, metadata_args) | MetadataService.update_documents_metadata(dataset, metadata_args) | ||||
| return 200 | |||||
| return {"result": "success"}, 200 | |||||
| api.add_resource(DatasetMetadataCreateApi, "/datasets/<uuid:dataset_id>/metadata") | api.add_resource(DatasetMetadataCreateApi, "/datasets/<uuid:dataset_id>/metadata") |
| args = parser.parse_args() | args = parser.parse_args() | ||||
| TagService.save_tag_binding(args) | TagService.save_tag_binding(args) | ||||
| return 200 | |||||
| return {"result": "success"}, 200 | |||||
| class TagBindingDeleteApi(Resource): | class TagBindingDeleteApi(Resource): | ||||
| args = parser.parse_args() | args = parser.parse_args() | ||||
| TagService.delete_tag_binding(args) | TagService.delete_tag_binding(args) | ||||
| return 200 | |||||
| return {"result": "success"}, 200 | |||||
| api.add_resource(TagListApi, "/tags") | api.add_resource(TagListApi, "/tags") |
| MetadataService.enable_built_in_field(dataset) | MetadataService.enable_built_in_field(dataset) | ||||
| elif action == "disable": | elif action == "disable": | ||||
| MetadataService.disable_built_in_field(dataset) | MetadataService.disable_built_in_field(dataset) | ||||
| return 200 | |||||
| return {"result": "success"}, 200 | |||||
| @service_api_ns.route("/datasets/<uuid:dataset_id>/documents/metadata") | @service_api_ns.route("/datasets/<uuid:dataset_id>/documents/metadata") | ||||
| MetadataService.update_documents_metadata(dataset, metadata_args) | MetadataService.update_documents_metadata(dataset, metadata_args) | ||||
| return 200 | |||||
| return {"result": "success"}, 200 |