(streams
  (let [pd (pagerduty "6548bec940214cfa9905a1d017925b93")]
    (by [:host :service]
        (changed-state
          (where (state "ok") (:resolve pd))
          (where (state "critical") (stable (* 15 60) :state (:trigger pd)))))))