       (do (vreset! completed? true)
           nil))))
 
-(defn input [event]
+(defn input [{:keys [onyx.core/task-map] :as event}]
   (map->AbsSeqReader {:event event 
                       :sequential (:seq/seq event) 
                       :rst (volatile! nil) 
                       :completed? (volatile! false) 
+                      :checkpoint? (not (false? (:seq/checkpoint? task-map)))
                       :offset (volatile! nil)}))
 
 (def reader-calls

            [onyx.plugin.protocols :as p]
            [taoensso.timbre :refer [fatal info debug] :as timbre]))

(defrecord AbsSeqReader [event sequential rst completed? offset]
  p/Plugin

  (start [this event]


  p/Checkpointed
  (checkpoint [this]
    (when checkpoint? @offset))

  (recover! [this _ checkpoint]
    (vreset! completed? false)
