 
 (onyx.api/shutdown-peer-group peer-group)
 
-(onyx.api/shutdown-env env)+(onyx.api/shutdown-env env)

            [onyx.lifecycle.metrics.throughput]
            [onyx.lifecycle.metrics.latency]
            [onyx.lifecycle.metrics.timbre]
            [onyx.api]))

(def id (java.util.UUID/randomUUID))

    :lifecycle/doc "Instruments a task's latency metrics per batch"}

   {:lifecycle/task :inc
    :lifecycle/calls :onyx.lifecycle.metrics.websocket/calls
    :websocket/address "ws://127.0.0.1:3000/metrics"
    :websocket/interval-ms 2000
    :lifecycle/doc "Sends metric data to a websocket."}

   {:lifecycle/task :inc
    :lifecycle/calls :onyx.lifecycle.metrics.timbre/calls
    :timbre/interval-ms 2000
    :lifecycle/doc "Prints task metrics to Timbre every 2000 ms"}
