chore: increase batch size (#51)

Logflare · Jan 10, 2024 · 1e4023a · 1e4023a
1 parent d8f3f52
commit 1e4023a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/pipeline.ex b/lib/pipeline.ex
@@ -18,7 +18,7 @@ defmodule Loadfest.Pipeline do
 
     def handle_demand(demand, state) when demand > 0 do
       messages = for _i <- 1..demand do
-          %Broadway.Message{data: Loadfest.Worker.make_batch(), acknowledger: {__MODULE__, :ack, 3}}
+          %Broadway.Message{data: Loadfest.Worker.make_batch(250), acknowledger: {__MODULE__, :ack, 3}}
       end
 
       {:noreply, messages, state}