     (throw (ex-info "Pending timeout cannot be greater than acking daemon timeout"
                     {:opts opts :pending-timeout pending-timeout}))))
 
+
 (defn clear-messenger-buffer!
   "Clears the messenger buffer of all messages related to prevous task lifecycle.
   In an ideal case, this might transfer messages over to another peer first as it help with retries."

      (catch Throwable e
        (throw (ex-info "Failed to resolve or build plugin on the classpath, did you require/import the file that contains this plugin?" {:symbol kw :exception e}))))))


(defn windowed-task? [event]
  (or (not-empty (:onyx.core/windows event))
      (not-empty (:onyx.core/triggers event))))

(defn exactly-once-task? [event]
  (boolean (get-in event [:onyx.core/task-map :onyx/uniqueness-key])))


                           (cons unique-id) ;; store the id at the head of the log entry
                           (state-extensions/store-log-entry state-log event ack-fn))
                      (doseq [t triggers]
                        (triggers/fire-trigger! event window-state t {:segment segment :context :new-segment})))
                    ;; Always update the filter, to freshen up the fact that the id has been re-seen
                    (when unique-id 
                      (swap! window-state update :filter state-extensions/apply-filter-id event unique-id))))
                (:leaves leaf))))
          (:tree results)
