@lindong28  I tried this a bit locally, and realized the command now has two pipes to `tee` (see line 58 as well)  When I drop the pipe to tee here on line 51 and keep the one below, the producer runs as expected. 