From 8df0cbac4a22d58879d74abed9d110485f438f79 Mon Sep 17 00:00:00 2001 From: schneefux Date: Sun, 23 Apr 2017 11:30:37 +0200 Subject: fuck transactions… MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- worker.js | 29 +++++++++++++---------------- 1 file changed, 13 insertions(+), 16 deletions(-) (limited to 'worker.js') diff --git a/worker.js b/worker.js index fab57b9..1de5746 100644 --- a/worker.js +++ b/worker.js @@ -198,23 +198,20 @@ function* chunks(arr) { async function calculate_global_point() { logger.info("crunching global stats, this could take a while"); - await seq.transaction({ autocommit: false }, async (transaction) => { - await Promise.map(global_points, async (tuple, idx, len) => { - const progress = Math.floor(100*100 * (1-idx/len)) / 100, - where_aggr = tuple[0], where_links = tuple[1]; - // aggregate participant_stats with our condition - let stats = await aggregate_stats(where_aggr); - if (stats != undefined) { - stats.updated_at = seq.fn("NOW"); - logger.info("inserting global stat", - { progress: progress }); - Object.assign(stats, where_links); - await model.GlobalPoint.upsert(stats, - { transaction: transaction }); - } else logger.warn("not enough data for this global stat!", + await Promise.map(global_points, async (tuple, idx, len) => { + const progress = Math.floor(100*100 * (1-idx/len)) / 100, + where_aggr = tuple[0], where_links = tuple[1]; + // aggregate participant_stats with our condition + let stats = await aggregate_stats(where_aggr); + if (stats != undefined) { + stats.updated_at = seq.fn("NOW"); + logger.info("inserting global stat", { progress: progress }); - }, { concurrency: MAXCONNS }); - }); + Object.assign(stats, where_links); + await model.GlobalPoint.upsert(stats); + } else logger.warn("not enough data for this global stat!", + { progress: progress }); + }, { concurrency: MAXCONNS }); logger.info("committing"); } -- cgit v1.3.1