Prüfe ob ich in einem delayed_job Prozess bin oder nicht

Question

Ich habe eine Rails App, in der ich delayed_job verwende. Ich möchte erkennen, ob ich in einem delayed_job-Prozess bin oder nicht; etwas wie

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 

Aber ich kann nicht herausfinden, wie. Dies ist, was ich verwende jetzt:

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 

Eine andere Lösung ist, wie @MrDanA sagte:

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

aber sie sind IMHO schwache Lösungen. Kann jemand eine bessere Lösung vorschlagen?

Answer 1

Die Art, wie ich damit umgehe, ist durch einen paranoiden Arbeiter. Ich benutze delayed_job für Video Transcoding, das auf meine Seite hochgeladen wurde. Innerhalb des Modells des Videos habe ich ein Feld namens video_processing, das standardmäßig auf 0/null gesetzt ist. Jedes Mal, wenn das Video durch den delayed_job transcodiert wird (egal ob beim Erstellen oder Aktualisieren der Videodatei), verwendet es die Hooks von delayed_job und aktualisiert die video_processing bei jedem Start des Jobs. Sobald der Auftrag abgeschlossen ist, wird die fertig gestellte Haken Sie das Feld aktualisieren, um 0.

Meiner Ansicht/Controller ich video.video_processing? ? "Video Transcoding in Progress" : "Video Fished Transcoding" tun kann

Answer 2

Vielleicht so etwas wie dieses. Fügen Sie ein Feld Ihrer Klasse und setzen Sie es, wenn Ihr invoke die Methode, die alle Ihre Arbeit von verzögerten Job macht:

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 

Hier ist, wie es aussieht:

Von Delayed Job:

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 ... 

der Konsole

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

Wie wäre es ENV [ 'PROC_TYPE']
nur von Heroku Speaking ... aber wenn man einen Arbeiter dyno sind, dann ist diese Option auf ‚Arbeitnehmer‘ Ich benutze es als meine „ich in einem DJ bin“

Answer 4

Dies funktioniert für mich:

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

Unix wird die Umgebungsvariable "_" auf den aktuellen Befehl setzen.

Es wird falsch sein, wenn Sie ein Bin-Skript namens "not_a_delayed_job" haben, aber tun Sie das nicht.