summaryrefslogtreecommitdiff
path: root/worker.js
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-23 10:16:28 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-23 10:16:28 +0200
commitb001f9cde6d945d3d2690767b60d60ef7c914613 (patch)
treebcbfb96f4efe3698f2192b11d1f359c5f37224ee /worker.js
parent29b2e6bd9e94cf7f61fe9112162439d010e3d44f (diff)
downloadcruncher-b001f9cde6d945d3d2690767b60d60ef7c914613.tar.gz
cruncher-b001f9cde6d945d3d2690767b60d60ef7c914613.zip
log more
Diffstat (limited to 'worker.js')
-rw-r--r--worker.js4
1 files changed, 2 insertions, 2 deletions
diff --git a/worker.js b/worker.js
index baf9a33..0674d5f 100644
--- a/worker.js
+++ b/worker.js
@@ -205,11 +205,11 @@ function* chunks(arr) {
let stats = await aggregate_stats(where_aggr);
if (stats != undefined) {
stats.updated_at = seq.fn("NOW");
- //logger.info("inserting global stats");
+ logger.info("inserting global stat");
Object.assign(stats, where_links);
await model.GlobalPoint.upsert(stats,
{ transaction: transaction });
- } // else logger.warn("not enough data for this global stat!");
+ } else logger.warn("not enough data for this global stat!");
}, { concurrency: MAXCONNS });
});
logger.info("committing");