             (let [tail (last (get-in @(:onyx.core/state event) [:timeout-pool]))]
               (doseq [m tail]
                 (when (p-ext/pending? pipeline event m)
-                  (taoensso.timbre/trace (format "Input retry message %s" m))
+                  (trace (format "Input retry message %s" m))
                   (->> (p-ext/retry-segment pipeline event m)
                        (lc/invoke-after-retry event compiled m))))
               (swap! (:onyx.core/state event) update :timeout-pool rsc/expire-bucket)

(defn start-lifecycle? [event]
  (let [rets (lc/invoke-start-task (:onyx.core/compiled event) event)]
    (when-not (:onyx.core/start-lifecycle? rets)
      (timbre/info (format "[%s] Peer chose not to start the task yet. Backing off and retrying..."
                           (:onyx.core/id event))))
    rets))

(defn add-acker-id [id m]


  (stop [component]
    (if-let [task-name (:onyx.core/task (:pipeline-data component))]
      (info (format "[%s] Stopping Task LifeCycle for %s" id task-name))
      (info (format "[%s] Stopping Task LifeCycle, failed to initialize task set up." id)))
    (when-let [event (:pipeline-data component)]

      ;; Fire all triggers on task completion.
