Fixing Broadway metric prefix

akoutmos · Mar 1, 2022 · 60788b8 · 60788b8
1 parent 412b7e9
commit 60788b8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/prom_ex/plugins/broadway.ex b/lib/prom_ex/plugins/broadway.ex
@@ -79,7 +79,7 @@ if Code.ensure_loaded?(Broadway) do
     @impl true
     def event_metrics(opts) do
       otp_app = Keyword.fetch!(opts, :otp_app)
-      metric_prefix = PromEx.metric_prefix(otp_app, :broadway)
+      metric_prefix = Keyword.get(opts, :metric_prefix, PromEx.metric_prefix(otp_app, :broadway))
 
       # Telemetry metrics will emit warnings if multiple handlers with the same names are defined.
       # As a result, this plugin supports gathering metrics on multiple processors and batches, but needs