Function patchDeleteRows

packages/server/src/services/dataset/index.ts:371–392

(ids: string[] = [], workspaceId: string)

// Delete dataset rows via ids
const patchDeleteRows = async (ids: string[] = [], workspaceId: string) => {
    try {
        const appServer = getRunningExpressApp()
        const datasetItemsToBeDeleted = await appServer.AppDataSource.getRepository(DatasetRow).find({
            where: {
                id: In(ids)
            }
        })
        const dbResponse = await appServer.AppDataSource.getRepository(DatasetRow).delete(ids)

        const datasetIds = [...new Set(datasetItemsToBeDeleted.map((item) => item.datasetId))]
        for (const datasetId of datasetIds) {
            await changeUpdateOnDataset(datasetId, workspaceId)
        }
        return dbResponse
    } catch (error) {
        throw new InternalFlowiseError(
            StatusCodes.INTERNAL_SERVER_ERROR,
            `Error: datasetService.patchDeleteRows - ${getErrorMessage(error)}`
        )
    }
}

export default {
    getAllDatasets,