                            :onyx.core/task-id task-id
                            :onyx.core/task (:name task)
                            :onyx.core/catalog catalog
-                           :onyx.core/workflow (extensions/read-chunk log :workflow job-id)
+                           :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))

          flow-conditions (extensions/read-chunk log :flow-conditions job-id)
          windows (extensions/read-chunk log :windows job-id)
          filtered-windows (wc/filter-windows windows (:name task))
          triggers (extensions/read-chunk log :triggers job-id)
          lifecycles (extensions/read-chunk log :lifecycles job-id)
          task-map (find-task catalog (:name task))]
      (assoc component 
             :catalog catalog :task task :flow-conditions flow-conditions :windows windows 
             :filtered-windows filtered-windows :triggers triggers :lifecycles lifecycles :task-map task-map)))
  (stop [component]
    (assoc component 


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