diff --git a/lib/reactor/builder/compose.ex b/lib/reactor/builder/compose.ex index ca2c3fb..8dcecf4 100644 --- a/lib/reactor/builder/compose.ex +++ b/lib/reactor/builder/compose.ex @@ -122,9 +122,9 @@ defmodule Reactor.Builder.Compose do ], name: name, async?: true, - impl: {Step.AnonFn, run: &{:ok, Map.fetch!(&1, :value)}}, + impl: {Step.ReturnArgument, argument: :value}, max_retries: 0, - ref: make_ref() + ref: name }} end