Fix streaming API double-JSON-encoding status IDs for deletes (#5069)
parent
3f3de38075
commit
909a6d4661
|
@ -264,7 +264,7 @@ const startWorker = (workerId) => {
|
||||||
const transmit = () => {
|
const transmit = () => {
|
||||||
const now = new Date().getTime();
|
const now = new Date().getTime();
|
||||||
const delta = now - queued_at;
|
const delta = now - queued_at;
|
||||||
const encodedPayload = typeof payload === 'number' ? payload : JSON.stringify(payload);
|
const encodedPayload = typeof payload === 'object' ? JSON.stringify(payload) : payload;
|
||||||
|
|
||||||
log.silly(req.requestId, `Transmitting for ${req.accountId}: ${event} ${encodedPayload} Delay: ${delta}ms`);
|
log.silly(req.requestId, `Transmitting for ${req.accountId}: ${event} ${encodedPayload} Delay: ${delta}ms`);
|
||||||
output(event, encodedPayload);
|
output(event, encodedPayload);
|
||||||
|
|
Reference in New Issue