Ugh

horror.clj

(defmacro single-key-aggregate-writer [name update-builder table]
  `(defbolt ~name [] [tuple# collector#]
     (let [count-maps# (tfield "count-maps")]
       (try
         (doseq [[agg-id# count-map#] count-maps#]
           (let [update-map# (~update-builder count-map#)]
             (dynamodb/update-item base/aws-credential ~table agg-id# update-map#)))
         (ack! collector# tuple#)
         (catch Exception e#
           (log/error (str "Exception commiting to " table#) (seq (.getStackTrace e#)))
           (log/error e#)
           (fail! collector# tuple#))))))