lib/rocket_job/batch/worker.rb in rocketjob-5.2.0 vs lib/rocket_job/batch/worker.rb in rocketjob-5.3.0
- old
+ new
@@ -26,13 +26,9 @@
# Results are stored in the output collection if `collect_output?`
# `nil` results from workers are kept if `collect_nil_output`
#
# If an exception was thrown the entire slice of records is marked as failed.
#
- # If the mongo_ha gem has been loaded, then the connection to mongo is
- # automatically re-established and the job will resume anytime a
- # Mongo connection failure occurs.
- #
# Thread-safe, can be called by multiple threads at the same time
def rocket_job_work(worker, re_raise_exceptions = false)
raise "Job must be started before calling #rocket_job_work" unless running?
start_time = Time.now