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

                                    (clj-mesos.scheduler/launch-tasks
                                      driver
                                      (:id offer)
                                      [{:name "Riak"
                                        :task-id (str "riak-node-" node)
                                        :slave-id (:slave-id offer)
                                        :resources {:cpus 1.0

                                (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
