   (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)))

        ]

    (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?

  (when-let [url (payload/clone-target-url payload)]
    (let [repo (git/fresh-clone url (workspace-dir (config :workspaces-path) url))
          uuid (str (java.util.UUID/randomUUID))]
      (println "Iterating over jobs for" url)
      (doseq [job (payload/all-jobs (-> repo :config :pipeline))]
        (let [job-with-uuid (assoc job :uuid uuid)]
          (println "--------------------------------------")
