diff --git a/lib/storage/dataset-clients.js b/lib/storage/dataset-clients.js index 2c5b0ae..04e9159 100644 --- a/lib/storage/dataset-clients.js +++ b/lib/storage/dataset-clients.js @@ -154,6 +154,10 @@ function upsertOrDeleteDatasetRecords(datasetId, datasetClientId, records, cb) { } else if (op === 'delete') { //remove the ref update['$pull'] = {'refs': datasetClientId}; + if(datasetClientId && datasetClientId.length !==0){ + // Remove set data to null as there are other refs already linked + delete update['$set'].data; + } } datasetRecordsCol.findOneAndUpdate({uid: record.uid}, update, {upsert: true, returnOriginal: false}, function(err, updated) { if (err) {