diff --git a/exec/binkit.js b/exec/binkit.js index 584ee13ad83a3b8cd717cf1dc9b7122310735a40..2df56449d78fab97bd64b2a3186d4ad6e151f88f 100644 --- a/exec/binkit.js +++ b/exec/binkit.js @@ -423,6 +423,14 @@ function callout_done(bp, semaphores) }); } }); + + // Remove flow files that have been completly processed. + Object.keys(bp.cb_data.binkit_flow_contents).forEach(function(flo) { + if (file_exists(flo)) { + if (bp.cb_data.binkit_flow_contents[flo].length == 0) + file_remove(flo); + } + }); } function callout(addr, scfg, semaphores)