diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2018-05-10 13:40:40 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2018-12-13 16:59:18 +0100 |
| commit | 0b16c89884f8c586b5edffa612af02144e3006a2 (patch) | |
| tree | 78e86f3b28f8401290e61f734bf6ae4782f9ec18 /backend/index.js | |
| parent | 62abcb8f563edcd639b5dc36b6467debbfbd3215 (diff) | |
| download | brokentalents-0b16c89884f8c586b5edffa612af02144e3006a2.tar.gz brokentalents-0b16c89884f8c586b5edffa612af02144e3006a2.zip | |
merge 'NoTalent' and null talents
Diffstat (limited to 'backend/index.js')
| -rw-r--r-- | backend/index.js | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/backend/index.js b/backend/index.js index 45869fb..9679a02 100644 --- a/backend/index.js +++ b/backend/index.js @@ -11,6 +11,7 @@ const R = require('ramda'), const loadFTimestamped = source.loadFTimestamped(config); const deriveStatistics = reduce.deriveStatistics(config.reduce); const aggregatePayloads = reduce.aggregatePayloads(config.reduce); +const cleanPayloads = reduce.cleanPayloads(config.reduce); const saveFPayloads = file.saveFPayloads(config.file); function main() { @@ -22,7 +23,7 @@ function main() { const futures = R.map(loadFTimestamped, laterMoments); Future.parallel(1, futures) - .map(R.compose(deriveStatistics, aggregatePayloads, R.unnest)) + .map(R.compose(deriveStatistics, aggregatePayloads, cleanPayloads, R.unnest)) .chain(saveFPayloads(config.file.reportPattern())) .fork(console.error, (d) => console.log(JSON.stringify(d, null, 2))); } |