     (dorun
       (map (sqs/deleting-consumer client
                                   (runner/decide-whether-to
-                                    run-job-from-message
+                                    (partial run-job-from-message
+                                             (config :workspaces-path)
+                                             (config :log-key))
                                     upstream-all-passed?))
            (filter no-pending-upstream-jobs?
                    (sqs/polling-receive client q

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

(defn- upstream-all-passed?

  "Process a queue item from the worker queue. Runs script, stores output.
  Currently outputs to both a big log and separate job logs.
  TODO: Remove big log."
  [workspaces-path big-log-key message]
  (println "--------------------------------------")
  (println "run-job-from-message")
  (let [{uuid     :uuid
