                                    :lifecycle/calls ::log-calls
                                    :lifecycle/doc "Lifecycle for printing the output of a task's batch"}]}))
 
-;;;;================- Core.Async  -===========================
+;;;;======================================================
+;;;;                 Core Async
 (def get-input-channel
   "Returns the same channel every time for an id."
   (memoize


;;;;=======================================================
;;;;                     SQL

(defn add-sql
  [{:keys [catalog lifecycles] :as job}]
  (let [sql-input (u/find-task-by-key catalog :onyx/plugin
                                      :onyx.plugin.sql/read-rows)
        sql-output (u/find-task-by-key catalog :onyx/plugin
                                       :onyx.plugin.sql/write-rows)]
    (-> job
        (u/add-to-job
         {:lifecycles


(defn add-seq
  [{:keys [catalog lifecycles] :as job} seq]
  (let [seq-input (u/find-task-by-key catalog :onyx/plugin :onyx.plugin.seq/input)]
    (-> job
        (u/add-to-job
         {:lifecycles
