Skip to content

Commit

Permalink
Extended Flow stats by adding worker/childprocess pid.
Browse files Browse the repository at this point in the history
  • Loading branch information
petersirka committed Mar 12, 2024
1 parent 90372a1 commit 6f05f60
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion flow-flowstream.js
Original file line number Diff line number Diff line change
Expand Up @@ -2447,7 +2447,7 @@ function MAKEFLOWSTREAM(meta) {
if (notifier % 3 === 0) {
notifier = 0;
if (Parent || Flow.$events.stats) {
let pstats = { paused: flow.paused, messages: flow.stats.messages, pending: flow.stats.pending, memory: flow.stats.memory, minutes: flow.stats.minutes, errors: flow.stats.errors, mm: flow.stats.mm };
let pstats = { paused: flow.paused, messages: flow.stats.messages, pending: flow.stats.pending, memory: flow.stats.memory, minutes: flow.stats.minutes, errors: flow.stats.errors, mm: flow.stats.mm, pid: process.pid };
if (Parent)
Parent.postMessage({ TYPE: 'stream/stats', data: pstats });
else if (Flow.$events.stats)
Expand Down

0 comments on commit 6f05f60

Please sign in to comment.