diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-19 12:18:27 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-19 12:18:27 +0200 |
| commit | 6d8540677de937aa77e3884a2e15811fdd49a496 (patch) | |
| tree | 0dc8acc09bfe012822fb0cd269db5efa67c97909 | |
| parent | c250e68b1e4e1c5816fe4dd1dc5c505e1fec8996 (diff) | |
| download | bridge-6d8540677de937aa77e3884a2e15811fdd49a496.tar.gz bridge-6d8540677de937aa77e3884a2e15811fdd49a496.zip | |
fix type error, getQueue -> getTarget
| -rw-r--r-- | service_crunch.js | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/service_crunch.js b/service_crunch.js index dfc6e6a..068204f 100644 --- a/service_crunch.js +++ b/service_crunch.js @@ -78,7 +78,7 @@ module.exports = class Cruncher extends Service { logger.info("sending participations to cruncher", { length: participations.length }); await Promise.map(participations, async (p) => - await this.forward(this.getQueue(category), + await this.forward(this.getTarget(category), p.api_id, { persistent: true, type: "player" })); // jobs with the type "player" won't be taken into account for global stats // global stats would increase on every player refresh otherwise @@ -113,7 +113,7 @@ module.exports = class Cruncher extends Service { order: [ ["id", "ASC"] ] }); await Promise.map(participations, async (p) => - await this.forward(this.getQueue(category), p.api_id, + await this.forward(this.getTarget(category), p.api_id, { persistent: true, type: "global" })); // update lpcid & refetch |