|
module HydraExtension
|
|
module Listener
|
|
class WorkerBeganFlag < Hydra::Listener::Abstract
|
|
# Fired after runner processes have been started
|
|
def worker_begin(worker)
|
|
FileUtils.touch File.expand_path(File.join(Dir.consistent_tmpdir, 'worker_began_flag'))
|
|
end
|
|
end
|
|
end
|
|
end
|