    :zookeeper/address "localhost:2181"
    :onyx/id id})
 
-(def onyx-server (d/start-distributed-coordinator coord-opts))
+(def onyx-server (onyx.api/start-distributed-coordinator coord-opts))
 
 (def onyx-port-2 (+ 10000 (rand-int 10000)))
 

(onyx.api/submit-job conn {:catalog catalog :workflow workflow})

(Thread/sleep 10000)
(d/stop-distributed-coordinator onyx-server)

(def results (hq-util/consume-queue! hq-config out-queue echo))


   :onyx.coordinator/port onyx-port-2
   :onyx.coordinator/revoke-delay 5000})

(def onyx-server-2 (future (onyx.api/start-distributed-coordinator coord-opts-2)))

(def conn (onyx.api/connect :distributed coord-opts))

