 
 ;;;;=======================================================
 ;;;;                     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)]
+  (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

                               :kafka/offset-reset :smallest
                               :kafka/force-reset? true}
                              kafka-settings)
        kafka-input    (u/find-task-by-key catalog :onyx/plugin
                                           :onyx.plugin.kafka/read-messages)
        kafka-output   (u/find-task-by-key catalog :onyx/plugin
                                           :onyx.plugin.kafka/write-messages)]
    (-> job
        (update-in [:catalog] (fn [entries]
                                (mapv (fn [entry]



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