Kiểm tra xem tôi có đang trong quá trình hoãn_job hay không

Question

Tôi có ứng dụng Rails trong đó tôi sử dụng delay_job. Tôi muốn phát hiện tôi có đang trong quá trình delay_job hay không; một cái gì đó như

if in_delayed_job? 
    # do something only if it is a delayed_job process... 
else 
    # do something only if it is not a delayed_job process... 
end 

Nhưng tôi không thể tìm ra cách. Đây là những gì tôi đang sử dụng hiện nay:

IN_DELAYED_JOB = begin 
    basename  = File.basename $0 
    arguments  = $* 
    rake_args_regex = /\Ajobs:/ 

    (basename == 'delayed_job') || 
    (basename == 'rake' && arguments.find{ |v| v =~ rake_args_regex }) 
end 

Một giải pháp khác là, như @MrDanA nói:

$ DELAYED_JOB=true script/delayed_job start 
# And in the app: 
IN_DELAYED_JOB = ENV['DELAYED_JOB'].present? 

nhưng họ IMHO giải pháp yếu. Bất cứ ai có thể đề xuất một giải pháp tốt hơn?

Answer 1

Cách mà tôi xử lý chúng là thông qua một nhân viên Paranoid. Tôi sử dụng delay_job để chuyển mã video đã được tải lên trang web của tôi. Trong mô hình của video, tôi có một trường được gọi là video_processing được đặt thành 0/null theo mặc định. Bất cứ khi nào video đang được chuyển mã bởi delay_job (cho dù khi tạo hoặc cập nhật tệp video), nó sẽ sử dụng các móc từ delay_job và sẽ cập nhật video_processing bất cứ khi nào công việc bắt đầu. Khi công việc hoàn tất, móc hoàn thành sẽ cập nhật các lĩnh vực để 0.

Theo quan điểm của tôi/điều khiển tôi có thể làm video.video_processing? ? "Video Transcoding in Progress" : "Video Fished Transcoding"

Answer 2

Có lẽ một cái gì đó như thế này. Thêm một trường để lớp học của bạn và đặt nó khi invoke bạn phương pháp mà làm tất cả công việc của bạn từ trì hoãn công việc:

class User < ActiveRecord::Base 
    attr_accessor :in_delayed_job 

    def queue_calculation_request 
    Delayed::Job.enqueue(CalculationRequest.new(self.id)) 
    end 

    def do_the_work 
    if (in_delayed_job) 
     puts "Im in delayed job" 
    else 
     puts "I was called directly" 
    end 
    end 

    class CalculationRequest < Struct.new(:id) 
    def perform 
     user = User.find(id) 
     user.in_delayed_job = true 
     user.do_the_work 
    end 

    def display_name 
     "Perform the needeful user Calculations" 
    end 
    end 
end 

Sau đây là cách nó trông giống:

Từ việc hoãn:

Worker(host:Johns-MacBook-Pro.local pid:67020)] Starting job worker 
Im in delayed job 
[Worker(host:Johns-MacBook-Pro.local pid:67020)] Perform the needeful user Calculations completed after 0.2787 
[Worker(host:Johns-MacBook-Pro.local pid:67020)] 1 jobs processed at 1.5578 j/s, 0 failed ... 

Từ giao diện điều khiển

user = User.first.do_the_work 
    User Load (0.8ms) SELECT "users".* FROM "users" WHERE "users"."id" = $1 LIMIT 1 [["id", 101]] 
I was called directly 

Answer 3

Làm thế nào về ENV [ 'PROC_TYPE']
Phát biểu duy nhất của Heroku ... nhưng khi bạn là một Dyno lao động, điều này được thiết lập để 'công nhân' tôi sử dụng nó như là tôi "Tôi đang ở trong một DJ"

Answer 4

này làm việc cho tôi:

def delayed_job_worker? 
    (ENV["_"].include? "delayed_job") 
end 

Unix sẽ đặt biến môi trường "_" thành lệnh hiện tại.

Sẽ rất sai nếu bạn có một tập lệnh bin có tên "not_a_delayed_job", nhưng đừng làm vậy.