   (fn [message]
     (let [ret (f message)]
       (println "--------------------------------------")
-      (println "Ran" f "Return value:" ret)
+      (println "Ran:" f)
+      (println "Return value:" ret)
       (println "Deleting message:" message)
       (println (sqs/delete client message))
       ret)))

    "worker"
    (let [client (sqs-client)
          q (sqs-queue client "cu-builds")]
      (dorun
        (map (deleting-consumer client
                                (runner/decide-whether-to

        ]

    (println "for" job-name)
    (io/put (results/log-key uuid job-name (build :exit))
            (build :out))
    (io/put (config :log-key)
            (str existing-log (build :out)))
    (build :out)))

(defn- upstream-all-passed?
