lib/pallets/worker.rb in pallets-0.7.0 vs lib/pallets/worker.rb in pallets-0.8.0
- old
+ new
@@ -114,10 +114,10 @@
))
backend.give_up(new_job, job)
end
def handle_job_success(context, job, job_hash)
- backend.save(job_hash['wfid'], job, serializer.dump_context(context.buffer))
+ backend.save(job_hash['wfid'], job_hash['jid'], job, serializer.dump_context(context.buffer))
end
def backoff_in_seconds(count)
count ** 4 + rand(6..10)
end