lib/backburner/connection.rb in backburner-allq-1.0.32 vs lib/backburner/connection.rb in backburner-allq-1.0.33

@@ -107,9 +107,11 @@
         pri: pri,
         delay: opt[:delay].to_i,
         ttr: ttr
       }
 
+      options[:shard_key] = opt[:shard_key] if opt[:shard_key]
+
       # Overwrite originals
       opt.merge!(options)
       @allq_wrapper.put(data, options)
     end