 
 (defrecord TaskInformation 
   [id log job-id task-id 
-   catalog task flow-conditions windows filtered-windows triggers lifecycles task-map]
+   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)

          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 


  (start [component]
    (try
      (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)
