   (fn [{:keys [onyx.core/id onyx.core/lifecycle-id]}]
     (taoensso.timbre/trace (format "[%s / %s] Closed batch plugin resources" id lifecycle-id))))
 
+
+

(defn compile-fc-exs [flow-conditions task-name]
  (compile-flow-conditions flow-conditions task-name :flow/thrown-exception?))

(defn run-task-lifecycle [init-event kill-ch ex-f]
  (try
    (while (first (alts!! [kill-ch] :default true))
      (-> init-event
          (inject-batch-resources)
          (read-batch)

        (release-messages! messenger pipeline-data)
        (thread (forward-completion-calls! pipeline-data completion-ch))
        (listen-for-sealer job-id task-id pipeline-data seal-resp-ch outbox-ch)
        (thread (run-task-lifecycle pipeline-data seal-resp-ch kill-ch ex-f))

        (assoc component :pipeline-data pipeline-data :seal-ch seal-resp-ch))
      (catch Exception e
