                            :onyx.core/monitoring monitoring
                            :onyx.core/outbox-ch outbox-ch
                            :onyx.core/seal-ch seal-resp-ch
+                           :onyx.core/task-kill-ch task-kill-ch
+                           :onyx.core/kill-ch kill-ch
                            :onyx.core/peer-opts opts
                            :onyx.core/fn (operation/resolve-task-fn catalog-entry)
                            :onyx.core/replica replica
                            :onyx.core/peer-replica-view peer-replica-view
                            :onyx.core/state state
-                           :onyx.core/test-entries-log test-full-log 
+                           :onyx.core/test-entries-log test-entries-log
                            :onyx.core/window-state (atom {})}
 
             pipeline (build-pipeline catalog-entry pipeline-data)

  [{:keys [onyx.core/windows onyx.core/window-state onyx.core/state-log] :as event}]
  (when (seq windows)
    (swap! window-state 
           (fn [state] (state-extensions/playback-log-entries state-log event state))))
  event)

(defn assign-windows
  [{:keys [onyx.core/windows onyx.core/window-state onyx.core/results] :as event}]
  (when (seq windows)
    (doseq [w windows]
      (doseq [msg (mapcat :leaves (:tree results))]

        (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 resolve-log [pipeline]
  (assoc pipeline :onyx.core/state-log (state-extensions/initialise-log :atom pipeline)))
;; place outside of task-lifecycle for testing persistence
(def test-entries-log (atom {})) 

(defrecord TaskLifeCycle
    [id log messenger-buffer messenger job-id task-id replica peer-replica-view restart-ch
