lib/rocket_job/plugins/job/worker.rb in rocketjob-2.0.0.rc1 vs lib/rocket_job/plugins/job/worker.rb in rocketjob-2.0.0.rc2

@@ -57,10 +57,12 @@
               when job.expired?
                 job.rocket_job_fail_on_exception!(worker_name) { job.destroy }
                 logger.info "Destroyed expired job #{job.class.name}, id:#{job.id}"
               else
                 job.worker_name = worker_name
-                job.rocket_job_fail_on_exception!(worker_name) { job.start }
+                job.rocket_job_fail_on_exception!(worker_name) do
+                  defined?(RocketJobPro) ? job.start! : job.start
+                end
                 return job if job.running?
               end
             end
           end