diff --git a/lib/broadway/topology.ex b/lib/broadway/topology.ex index 53cebd7..789104d 100644 --- a/lib/broadway/topology.ex +++ b/lib/broadway/topology.ex @@ -374,7 +374,7 @@ defmodule Broadway.Topology do concurrency: options[:concurrency] ] ++ options - opts = [name: name] + opts = start_options(name, options) spec = %{ start: {BatcherStage, :start_link, [args, opts]},