 
 (defn start-offer-matcher!
   "Create a thread to repeatedly pull from matcher-chan and have the offer matched."
-  [conn pending-jobs-atom matcher-chan]
+  [conn pending-jobs-atom matcher-chan rescinded-offer-id-cache]
   (async/thread
     (log/debug "offer matcher started")
     (try

               {:instance (str (count (:job/instance job-ent)))})
             "UTF-8")
     executor-key executor-value}))

(timers/deftimer [cook-mesos scheduler handle-status-update-duration])
(meters/defmeter [cook-mesos scheduler tasks-killed-in-status-update])

      (resourceOffers [driver offers]
                      (case
                          (async/alt!!
                           [[offer-chan [offers driver @fid]]] (log/debug "Passed" (count offers) "to incubator")
                           :default :back-pressure
                           :priority true)
                        :back-pressure (do
                                         (log/warn "Back pressure on offer-incubator. Declining" (count offers) "offers")
                                         (meters/mark! offer-back-pressure)
                                         (decline-offers driver (map :id offers)))
                        nil))
