diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-09-28 20:00:10 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-09-28 20:00:10 +0200 |
| commit | c7aa7b45116e57ce51efc310dd7cc2dcdde98715 (patch) | |
| tree | abb005398f55b9b91223294145f267dc3ccd94fc | |
| parent | b97200c33eb79311d01702eb648a0745f0297889 (diff) | |
| download | bridge-c7aa7b45116e57ce51efc310dd7cc2dcdde98715.tar.gz bridge-c7aa7b45116e57ce51efc310dd7cc2dcdde98715.zip | |
send phase ID as string, fixes OOM errors
| -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 b326da8..4f73d0c 100644 --- a/service_crunch.js +++ b/service_crunch.js @@ -166,10 +166,10 @@ module.exports = class Cruncher extends Service { }); // tables are split, and so are services and queues await Promise.map(phases, async (ph) => - await this.forward(this.getTarget(category + "_phase"), ph.id, + await this.forward(this.getTarget(category + "_phase"), ph.id.toString(), { persistent: true })); await Promise.map(phases, async (ph) => - await this.forward(this.getTarget(category + "_ban"), ph.id, + await this.forward(this.getTarget(category + "_ban"), ph.id.toString(), { persistent: true })); // update lphcid & refetch |