   "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."
-  [message]
+  [workspaces-path big-log-key message]
   (println "--------------------------------------")
   (println "run-job-from-message")
   (let [{uuid     :uuid

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

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