 
 
 ;;;;============================================================
-;;;;                      Metrics
+;;;;                    Metrics
 (defn add-metrics
   [job task]
   (u/add-to-job job

              [cheshire.core :as json]))


;;;;================- Logging -===========================

(defn log-batch [event lifecycle]
  (let [task-name (:onyx/name (:onyx.core/task-map event))]
    (doseq [m (map :message (mapcat :leaves (:tree (:onyx.core/results event))))]

                                   :lifecycle/calls ::log-calls
                                   :lifecycle/doc "Lifecycle for printing the output of a task's batch"}]}))

;;;;======================================================
;;;;                 Core Async
(def get-input-channel
  "Returns the same channel every time for an id."
  (memoize
