diff --git a/src/fonda/step.cljs b/src/fonda/step.cljs index 18fcf2d..2541057 100644 --- a/src/fonda/step.cljs +++ b/src/fonda/step.cljs @@ -53,13 +53,13 @@ fn-or-keyword)) (defn step->record - [{:keys [tap inject] :as step}] + [{:keys [tap inject fn processor] :as step}] (let [step (cond tap (map->Tap (update step :tap resolve-function)) - (:fn step) (map->Processor (-> step - (update :fn resolve-function) - (assoc :is-anomaly-error? (or (:is-anomaly-error? step) (constantly true))))) + (or processor fn) (map->Processor (-> step + (update :fn resolve-function) + (assoc :is-anomaly-error? (or (:is-anomaly-error? step) (constantly true))))) inject (map->Injector (update step :inject resolve-function)))] (update step :name keyword)))