updated delayed_job to be fork-able, and made it change the name of t…

…he process to reflect its current task when busy
woahdae · Jun 22, 2009 · 7df707a · 7df707a
1 parent 266fc15
commit 7df707a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/delayed/job.rb b/lib/delayed/job.rb
@@ -214,7 +214,11 @@ def self.work_off(num = 100)
 
     # Moved into its own method so that new_relic can trace it.
     def invoke_job
+      base_name = $0
+      $0 = "#{base_name}: #{self.payload_object.to_s}"
       payload_object.perform
+    ensure
+      $0 = base_name
     end
 
   private

diff --git a/lib/delayed/worker.rb b/lib/delayed/worker.rb
@@ -10,6 +10,8 @@ class Worker
     end
 
     def initialize(options={})
+      Delayed::Job.worker_name = "host:#{Socket.gethostname} pid:#{Process.pid}" rescue "pid:#{Process.pid}"
+
       @quiet = options[:quiet]
       Delayed::Job.min_priority = options[:min_priority] if options.has_key?(:min_priority)
       Delayed::Job.max_priority = options[:max_priority] if options.has_key?(:max_priority)