 
   (start [component]
     (try
-      (let [{:keys [catalog task flow-conditions windows filtered-windows triggers lifecycles task-map]} task-information
+      (let [{:keys [workflow catalog task flow-conditions windows filtered-windows triggers lifecycles task-map]} task-information
             ;; Number of buckets in the timeout pool is covered over a 60 second
             ;; interval, moving each bucket back 60 seconds / N buckets
             input-retry-timeout (arg-or-default :onyx/input-retry-timeout task-map)


(defrecord TaskInformation 
  [id log job-id task-id 
   catalog task flow-conditions windows filtered-windows triggers lifecycles task-map]
  component/Lifecycle
  (start [component]
    (let [catalog (extensions/read-chunk log :catalog job-id)

                           :onyx.core/task-id task-id
                           :onyx.core/task (:name task)
                           :onyx.core/catalog catalog
                           :onyx.core/workflow workflow 
                           :onyx.core/flow-conditions flow-conditions
                           :onyx.core/compiled (->CompiledGroupingFn (g/task-map->grouping-fn task-map))
                           :onyx.core/task->group-by-fn (g/compile-grouping-fn catalog (:egress-ids task))
