lib/fanforce/worker/errors.rb in fanforce-worker-0.31.0 vs lib/fanforce/worker/errors.rb in fanforce-worker-0.32.0

@@ -140,9 +140,10 @@
   end
 
   def self.retry(queue_id, raw_error)
     error = format(raw_error.symbolize_keys)
     payload = MultiJson.load(error[:raw_json], symbolize_keys: true) rescue {}
+    queue_id = queue_id.gsub(":#{ENV['DEVELOPER_EMAIL']}", '') if ENV['DEVELOPER_EMAIL']
     Fanforce::Worker.set_config(iron_token: error[:iron_token], iron_project_id: error[:iron_project_id])
     Fanforce::Worker.enqueue(queue_id, payload, :retries => error[:retries] + 1)
     delete(queue_id, error[:error_id])
   end