                                                ACKER-FAIL-STREAM-ID
                                                [root]))
                        (let [delta (tuple-time-delta! tuple-start-times tuple)]
-                         (task/apply-hooks (:user-context task-data) .boltFail (BoltFailInfo. tuple delta))
+                         (task/apply-hooks user-context .boltFail (BoltFailInfo. tuple delta))
                          (when (sampler)
                            (stats/bolt-failed-tuple! executor-stats
                                                      (.getSourceComponent tuple)

                                                 [root (bit-xor id ack-val)])
                           ))
                       (let [delta (tuple-time-delta! tuple-start-times tuple)]
                         (task/apply-hooks (:user-context task-data) .boltAck (BoltAckInfo. tuple delta))
                         (when (sampler)
                           (stats/bolt-acked-tuple! executor-stats
                                                    (.getSourceComponent tuple)

                                (or out-tasks [])))]]
      (.prepare bolt-obj
                storm-conf
                user-context
                (OutputCollector.
                  (reify IOutputCollector
                     (emit [this stream anchors values]
