lib/fanforce/worker/errors.rb in fanforce-worker-0.20.1 vs lib/fanforce/worker/errors.rb in fanforce-worker-0.21.0

@@ -139,11 +139,12 @@
     redis.hgetall("ERRORS:#{queue_id}:#{error_id}")
   end
 
   def self.retry(queue_id, raw_error)
     error = format(raw_error.symbolize_keys)
+    params = MultiJson.load(error[:raw_json], symbolize_keys: true) rescue {}
     Fanforce::Worker.set_config(iron_token: error[:iron_token], iron_project_id: error[:iron_project_id])
-    Fanforce::Worker.enqueue(queue_id, error, :retries => error[:retries] + 1)
+    Fanforce::Worker.enqueue(queue_id, params, :retries => error[:retries] + 1)
     delete(queue_id, error[:error_id])
   end
 
 end