diff --git a/lib/quantum/executor_supervisor.ex b/lib/quantum/executor_supervisor.ex index 809ff8d..a766fd1 100644 --- a/lib/quantum/executor_supervisor.ex +++ b/lib/quantum/executor_supervisor.ex @@ -51,7 +51,7 @@ defmodule Quantum.ExecutorSupervisor do if Util.gen_stage_v12?() do def init( %InitOpts{ - execution_broadcaster: execution_broadcaster + execution_broadcaster_reference: execution_broadcaster } = opts ) do ConsumerSupervisor.init(