 ;;;;=======================================================
 ;;;;                     SQL
 (defn add-sql-input
+  "Add's sql output lifecycles to a task. Opts should include JDBC
+  connection specs
+  {:sql/classname ...
+   :sql/subprotocol ...
+   :sql/subname ...
+   :sql/user ...
+   :sql/password ...
+   :sql/table ...}"
   ([job task] (add-sql-input job task nil))
   ([job task opts]
    (if-let [entry (first (filter #(= (:onyx/name %) task) (:catalog job)))]

                                 (replace {entry (merge opts entry)} catalog)))))))

(defn add-sql-output
  ([job task] (add-sql-output job task nil))
  ([job task opts]
   (if-let [entry (first (filter #(= (:onyx/name %) task) (:catalog job)))]

;;;;                    Metrics

(defn add-metrics
  "Add's throughput and latency metrics to a task"
  [job task opts]
  (if-let [entry (first (filter #(= (:onyx/name %) task) (:catalog job)))]
    (-> job
