lib/rocket_job/sliced/input.rb in rocketjob-6.2.0 vs lib/rocket_job/sliced/input.rb in rocketjob-6.3.0

@@ -103,18 +103,18 @@
 
       # Requeue all failed slices
       def requeue_failed
         failed.update_all(
           "$unset" => {worker_name: nil, started_at: nil},
-          "$set"   => {state: :queued}
+          "$set"   => {state: "queued"}
         )
       end
 
       # Requeue all running slices for a server or worker that is no longer available
       def requeue_running(worker_name)
         running.where(worker_name: /\A#{worker_name}/).update_all(
           "$unset" => {worker_name: nil, started_at: nil},
-          "$set"   => {state: :queued}
+          "$set"   => {state: "queued"}
         )
       end
 
       # Returns the next slice to work on in id order
       # Returns nil if there are currently no queued slices