Mycelium: Clojure를 위한 스키마 강제 및 구성 가능한 워크플로우 라이브러리

(defmethod cell/cell-spec :math/double [_]
  {:id :math/double
   :handler (fn [_resources data] (assoc data :result (* 2 (:x data))))
   :schema {:input [:map [:x :int]]
            :output [:map [:result :int]]}})

(myc/run-workflow
  {:cells {:start :math/double :add :math/add-ten}
   :edges {:start {:done :add} :add {:done :end}}
   :dispatches {:start [[:done (constantly true)]]
                :add [[:done (constantly true)]]}}
  {} {:x 5})

:joins {:fetch-data {:cells [:fetch-profile :fetch-orders]
                     :strategy :parallel}}
:edges {:start {:authorized :fetch-data, :unauthorized :render-error}
        :fetch-data {:done :render-summary, :failure :render-error}}

:resilience {:start {:timeout {:timeout-ms 5000}
                     :retry {:max-attempts 3 :wait-ms 200}
                     :circuit-breaker {:failure-rate 50}}}

(defmethod cell/cell-spec :review/check [_]
  {:id :review/check
   :handler (fn [_ data]
              (assoc data :mycelium/halt {:reason :needs-approval}))})