mirror of
https://github.com/ash-project/reactor.git
synced 2024-09-19 12:53:19 +12:00
fix: avoid false positives on is reactor check
This commit is contained in:
parent
eeb9614271
commit
99f5814283
1 changed files with 3 additions and 3 deletions
|
@ -140,11 +140,11 @@ defmodule Reactor do
|
||||||
def run(reactor, inputs \\ %{}, context \\ %{}, options \\ [])
|
def run(reactor, inputs \\ %{}, context \\ %{}, options \\ [])
|
||||||
|
|
||||||
def run(reactor, inputs, context, options) when is_atom(reactor) do
|
def run(reactor, inputs, context, options) when is_atom(reactor) do
|
||||||
with Reactor <- reactor.spark_is() do
|
if Spark.Dsl.is?(reactor, Reactor) do
|
||||||
run(reactor.reactor(), inputs, context, options)
|
run(reactor.reactor(), inputs, context, options)
|
||||||
|
else
|
||||||
|
{:error, "Module `#{inspect(reactor)}` is not a Reactor module"}
|
||||||
end
|
end
|
||||||
rescue
|
|
||||||
UndefinedFunctionError -> {:error, "Module `#{inspect(reactor)}` is not a Reactor module"}
|
|
||||||
end
|
end
|
||||||
|
|
||||||
def run(reactor, inputs, context, options)
|
def run(reactor, inputs, context, options)
|
||||||
|
|
Loading…
Reference in a new issue