diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-01 14:07:11 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-01 14:07:11 +0200 |
| commit | c60aeb4bb9e4381182ed0c30793ea6612ceaa283 (patch) | |
| tree | 2566f73b1ffa90950601acdc3f41169c75501084 /worker.js | |
| parent | e186783d9e1d52cab965fe614780221a9859dd04 (diff) | |
| download | cruncher-c60aeb4bb9e4381182ed0c30793ea6612ceaa283.tar.gz cruncher-c60aeb4bb9e4381182ed0c30793ea6612ceaa283.zip | |
specify global_point table by env var
Diffstat (limited to 'worker.js')
| -rw-r--r-- | worker.js | 2 |
1 files changed, 2 insertions, 0 deletions
@@ -20,6 +20,7 @@ const amqp = require("amqplib"), const RABBITMQ_URI = process.env.RABBITMQ_URI, DATABASE_URI = process.env.DATABASE_URI, + CRUNCH_TABLE = process.env.CRUNCH_TABLE || "global_point", QUEUE = process.env.QUEUE || "crunch", LOGGLY_TOKEN = process.env.LOGGLY_TOKEN, // size of connection pool @@ -125,6 +126,7 @@ if (LOGGLY_TOKEN) replacements: { build_regex_start: '^([[:digit:]]+;[[:digit:]]+,)*(', build_regex_end: ')+(,[[:digit:]]+;[[:digit:]]+)*$', + crunch_table: CRUNCH_TABLE, participant_api_ids: api_ids_global }, type: seq.QueryTypes.UPSERT |