I am trying to lower the rate limit inside a handle_failed callback. Basically I want if the processing keeps failing to lower the rate exponentially to not flod the CPU and neither the bubtracker.
Docs say to get current rate limit like this:
Broadway.get_rate_limiting(broadway)
#=> {:ok, %{allowed_messages: 2000, interval: 1000}}
but what is broadway? I tried to use self() to get access to the broadway pipeline but without success.