aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/base-request-scheduler.js
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib/base-request-scheduler.js')
-rw-r--r--server/lib/base-request-scheduler.js8
1 files changed, 4 insertions, 4 deletions
diff --git a/server/lib/base-request-scheduler.js b/server/lib/base-request-scheduler.js
index 4709c7960..7378971c8 100644
--- a/server/lib/base-request-scheduler.js
+++ b/server/lib/base-request-scheduler.js
@@ -66,10 +66,10 @@ module.exports = class BaseRequestScheduler {
66 err = err ? err.message : 'Status code not 20x : ' + res.statusCode 66 err = err ? err.message : 'Status code not 20x : ' + res.statusCode
67 logger.error('Error sending secure request to %s pod.', toPod.host, { error: err }) 67 logger.error('Error sending secure request to %s pod.', toPod.host, { error: err })
68 68
69 return callback(false) 69 return callback(err)
70 } 70 }
71 71
72 return callback(true) 72 return callback(null)
73 }) 73 })
74 } 74 }
75 75
@@ -99,8 +99,8 @@ module.exports = class BaseRequestScheduler {
99 const requestToMake = requestsToMakeGrouped[hashKey] 99 const requestToMake = requestsToMakeGrouped[hashKey]
100 const toPod = requestToMake.toPod 100 const toPod = requestToMake.toPod
101 101
102 this.makeRequest(toPod, requestToMake.endpoint, requestToMake.datas, (success) => { 102 this.makeRequest(toPod, requestToMake.endpoint, requestToMake.datas, (err) => {
103 if (success === false) { 103 if (err) {
104 badPods.push(requestToMake.toPod.id) 104 badPods.push(requestToMake.toPod.id)
105 return callbackEach() 105 return callbackEach()
106 } 106 }