             (>!! (:onyx.core/complete-ch event) true))))
       (recur))))
 
-(defrecord TaskLifeCycle [id log queue job task opts]
+(defrecord TaskLifeCycle [id log queue job task err-ch opts]
   component/Lifecycle
 
   (start [component]


    component))

(defn task-lifecycle [id log queue job task opts]
  (map->TaskLifeCycle {:id id :log log :queue queue :job job
                       :task task :opts opts}))

(dire/with-post-hook! #'munge-start-lifecycle
  (fn [{:keys [onyx.core/id onyx.core/lifecycle-id onyx.core/start-lifecycle?] :as event}]

        :pipeline-data pipeline-data)))

  (stop [component]
    (taoensso.timbre/info (format "[%s] Stopping Task LifeCycle for %s" id (:task/name task)))

    (close! (:open-session-kill-ch component))
    (<!! (:open-session-dead-ch component))
