           (when (and (first (alts!! [kill-ch task-kill-ch] :default true))
                      (or (not (common/job-covered? replica-state job-id))
                          (not (common/any-ackers? replica-state job-id))))
-            (taoensso.timbre/info (format "[%s] Not enough virtual peers have warmed up to start the task yet, backing off and trying again..." id))
+            (info (format "[%s] Not enough virtual peers have warmed up to start the task yet, backing off and trying again..." id))
             (Thread/sleep (arg-or-default :onyx.peer/job-not-ready-back-off opts))
             (recur @replica)))
 
-        (taoensso.timbre/info (format "[%s] Enough peers are active, starting the task" id))
+        (info (format "[%s] Enough peers are active, starting the task" id))
 
         (let [input-retry-segments-ch (input-retry-segments! messenger pipeline-data input-retry-timeout task-kill-ch)
               aux-ch (launch-aux-threads! messenger pipeline-data outbox-ch seal-ch completion-ch task-kill-ch)

(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]


(defn write-batch [{:keys [pipeline]} event]
  (let [rets (merge event (p-ext/write-batch pipeline event))]
    (trace (format "[%s / %s] Wrote %s segments"
                   (:onyx.core/id rets)
                   (:onyx.core/lifecycle-id rets)
                   (count (:onyx.core/results rets))))
    rets))

(defn launch-aux-threads!
