diff --git a/app/jobs/abf_worker/base_observer.rb b/app/jobs/abf_worker/base_observer.rb
index 8bc2c91b1..984a57686 100644
--- a/app/jobs/abf_worker/base_observer.rb
+++ b/app/jobs/abf_worker/base_observer.rb
@@ -11,7 +11,7 @@ module AbfWorker
 
     attr_accessor :status, :options
 
-    def perform(options)
+    def perform_with_ar_connection(options)
       @status         = options['status'].to_i
       @options        = options
       real_perform