diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-22 09:47:46 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-22 09:47:46 +0200 |
| commit | c907f985a63162f9cf38aa55b4d7806139d203e7 (patch) | |
| tree | 24fc2db996f1c0f9b9bf9fcf1986d685fd370331 | |
| parent | 77069d9c0a41c66dbaed5452df6880c349a3efc8 (diff) | |
| download | shrinker-c907f985a63162f9cf38aa55b4d7806139d203e7.tar.gz shrinker-c907f985a63162f9cf38aa55b4d7806139d203e7.zip | |
nerf items
| -rw-r--r-- | worker.js | 10 |
1 files changed, 5 insertions, 5 deletions
@@ -85,7 +85,7 @@ function flatten(obj) { while (true) { try { seq = new Seq(DATABASE_URI, { - logging: false, + //logging: false, max: 10 }); rabbit = await amqp.connect(RABBITMQ_URI, { heartbeat: 120 }); @@ -321,9 +321,9 @@ function flatten(obj) { let itms = []; itms = itms.concat(item_use(participant.attributes.stats.items, "final")); - itms = itms.concat(item_use(item_arr_from_obj(participant.attributes.stats.itemGrants), "grant")); - itms = itms.concat(item_use(item_arr_from_obj(participant.attributes.stats.itemUses), "use")); - itms = itms.concat(item_use(item_arr_from_obj(participant.attributes.stats.itemSells), "sell")); + //itms = itms.concat(item_use(item_arr_from_obj(participant.attributes.stats.itemGrants), "grant")); + //itms = itms.concat(item_use(item_arr_from_obj(participant.attributes.stats.itemUses), "use")); + //itms = itms.concat(item_use(item_arr_from_obj(participant.attributes.stats.itemSells), "sell")); // for debugging: /* @@ -391,7 +391,7 @@ function flatten(obj) { // upsert whole batch in parallel logger.info("inserting batch into db"); await seq.transaction({ autocommit: false }, async (transaction) => { - await Promise.all([ + return Promise.all([ Promise.map(chunks(match_records), async (m_r) => model.Match.bulkCreate(m_r, { ignoreDuplicates: true, // should not happen |