Solved! I just needed to increase the value of max_latency in ThreadedStreamer.
I also needed to use Gunicorn and set --threads to the value of my batch size in order to process all of them at once. I guess it would work with a lower value of threads too.
如题