         (fn [e & _] (.printStackTrace e)))
 
       (assoc component
+        :open-session-kill-ch open-session-kill-ch
         :read-batch-ch read-batch-ch
         :decompress-batch-ch decompress-batch-ch
         :apply-fn-ch apply-fn-ch

  (stop [component]
    (prn "Stopping Task Pipeline")

    (future-cancel (:open-session-loop component))

    (close! (:read-batch-ch component))
    (close! (:decompress-batch-ch component))
    (close! (:apply-fn-ch component))

  (start [component]
    (prn "Starting Task Pipeline")
    
    (let [open-session-kill-ch (chan 1)
          read-batch-ch (chan 1)
          decompress-batch-ch (chan 1)
          apply-fn-ch (chan 1)
          compress-batch-ch (chan 1)
