lib/rocket_job/sliced/input.rb in rocketjob-5.4.1 vs lib/rocket_job/sliced/input.rb in rocketjob-6.0.0.rc1
- old
+ new
@@ -137,10 +137,10 @@
# TODO: Will it perform faster without the id sort?
# I.e. Just process on a FIFO basis?
document = all.queued.
sort("_id" => 1).
find_one_and_update(
- {"$set" => {worker_name: worker_name, state: :running, started_at: Time.now}},
+ {"$set" => {worker_name: worker_name, state: "running", started_at: Time.now}},
return_document: :after
)
document.collection_name = collection_name if document
document
end