 (def garbage-hack "I hate this")
 
 (defn scheduler
+  [pending running]
   []
-  (let [pending (atom #{1 2})
-        used-hosts (atom #{})
+  (let [used-hosts (atom #{})
         ;;this contains pairs of [executor-id slave-id]
         active-executors (atom #{})
         executor-id->hostname (atom {})]

                              (println "sending command" command)
                              (clj-mesos.scheduler/send-framework-message driver executor-id slave-id (.getBytes (pr-str command))))))
                        (when (= :task-running (:state status))
                          (swap! active-executors conj [(:executor-id status) (:slave-id status)])))))
      (resourceOffers [driver offers]
                      (future
                        (locking garbage-hack

                                (clj-mesos.scheduler/decline-offer driver (:id offer))))
                            (catch Exception e
                              (.printStackTrace e)))))))))

(defn -main
  [master]
