handle error while running persistent tasks

miyucy · Apr 29, 2009 · ffac662 · ffac662
1 parent 6097a40
commit ffac662
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/server/lib/meta_worker.rb b/server/lib/meta_worker.rb
@@ -127,7 +127,14 @@ def worker_init
         invoke_user_method(:create,worker_options[:data])
       end
       if run_persistent_jobs?
-        add_periodic_timer(persistent_delay.to_i) { check_for_enqueued_tasks }
+        add_periodic_timer(persistent_delay.to_i) {
+          begin
+            check_for_enqueued_tasks
+          rescue Object => e
+            puts("Error while running persistent task : #{Time.now}")
+            log_exception(e.backtrace)
+          end
+        }
       end
       write_pid_file(t_worker_key)
     end