Function updateDatasetRow

packages/server/src/services/dataset/index.ts:321–346

(id: string, body: any)

// Update row for a dataset
const updateDatasetRow = async (id: string, body: any) => {
    try {
        const appServer = getRunningExpressApp()
        const item = await appServer.AppDataSource.getRepository(DatasetRow).findOneBy({
            id: id
        })
        if (!item) throw new InternalFlowiseError(StatusCodes.NOT_FOUND, `Dataset Row ${id} not found`)

        const dataset = await appServer.AppDataSource.getRepository(Dataset).findOneBy({
            id: item.datasetId,
            workspaceId: body.workspaceId
        })
        if (!dataset) throw new InternalFlowiseError(StatusCodes.NOT_FOUND, `Dataset Row ${id} not found`)

        item.input = body.input
        item.output = body.output
        const result = await appServer.AppDataSource.getRepository(DatasetRow).save(item)
        await changeUpdateOnDataset(item.datasetId, body.workspaceId)
        return result
    } catch (error) {
        throw new InternalFlowiseError(
            StatusCodes.INTERNAL_SERVER_ERROR,
            `Error: datasetService.updateDatasetRow - ${getErrorMessage(error)}`
        )
    }
}

// Delete dataset row via id
const deleteDatasetRow = async (id: string, workspaceId: string) => {