                                                                           :host-path "/var/log/riak-executor"
                                                                           :mode :rw} ]}
                                                    :command {:shell false}}
-                                        }]))
+                                        }] (println "launch-exec-info"))))
                                 (clj-mesos.scheduler/decline-offer driver (:id offer))))
                             (catch Exception e
                               (.printStackTrace e)))))))))

                              (= (:task-state status) :task-running) nil
                              :else
                              (do
                                (swap! running disj (id-from-status status))
                                (swap! pending conj (id-from-status status))))))
                        (catch Exception e
                          (.printStackTrace e)))))
      (resourceOffers [driver offers]

                                (println "sent")
                                (clj-mesos.scheduler/send-framework-message driver executor slave (.getBytes (pr-str command))))))
                          (when (= :task-running (:state status))
                            (swap! active-executors conj {:executor-id (read-string (String. (:data status) "UTF-8"))
                                                          :slave-id (:slave-id status)}))
                          (let [id-from-status (comp #(Integer/parseInt %) str last :task-id)] 
                            (cond 
                              (= (:task-state status) :task-staging) nil
