|
|
@ -38,12 +38,16 @@ exports.updateRelatedFormula = async (appId, table, enrichedRows) => { |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
for (let tableId of table.relatedFormula) { |
|
|
for (let tableId of table.relatedFormula) { |
|
|
|
|
|
let relatedTable |
|
|
try { |
|
|
try { |
|
|
// no rows to update, skip
|
|
|
// no rows to update, skip
|
|
|
if (!relatedRows[tableId] || relatedRows[tableId].length === 0) { |
|
|
if (!relatedRows[tableId] || relatedRows[tableId].length === 0) { |
|
|
continue |
|
|
continue |
|
|
} |
|
|
} |
|
|
const relatedTable = await db.get(tableId) |
|
|
relatedTable = await db.get(tableId) |
|
|
|
|
|
} catch (err) { |
|
|
|
|
|
// no error scenario, table doesn't seem to exist anymore, ignore
|
|
|
|
|
|
} |
|
|
for (let column of Object.values(relatedTable.schema)) { |
|
|
for (let column of Object.values(relatedTable.schema)) { |
|
|
// needs updated in related rows
|
|
|
// needs updated in related rows
|
|
|
if ( |
|
|
if ( |
|
|
@ -60,9 +64,6 @@ exports.updateRelatedFormula = async (appId, table, enrichedRows) => { |
|
|
) |
|
|
) |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} catch (err) { |
|
|
|
|
|
// no error scenario, table doesn't seem to exist anymore, ignore
|
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
await Promise.all(promises) |
|
|
await Promise.all(promises) |
|
|
|