        :onyx/plugin :onyx.plugin.core-async/input
        :onyx/type :input
        :onyx/medium :core.async
+       :onyx/assign-watermark-fn ::watermark-fn
        :onyx/batch-size batch-size
        :onyx/batch-timeout batch-timeout
        :onyx/max-peers 1

    :onyx/doc "core.async plugin base lifecycle"}])

;; <<< BEGIN FILL ME IN PART 1 >>>

(def windows
  [])



(def workflow
  [[:read-segments :bucket-page-views]])

(defn watermark-fn [segment]
  ;;  <<< FILL ME IN >>>
  )

;;; Catalogs ;;;

