diff --git a/delayed_job.gemspec b/delayed_job.gemspec index 1ccd44ae7..fd2fddf46 100644 --- a/delayed_job.gemspec +++ b/delayed_job.gemspec @@ -30,7 +30,7 @@ Gem::Specification.new do |s| lib/delayed/worker.rb lib/delayed_job.rb tasks/jobs.rake - tasks/merbtasks.rb + tasks/tasks.rb ] s.test_files = %w[ spec/database.rb diff --git a/lib/delayed_job.rb b/lib/delayed_job.rb index a90456376..9c9206cb0 100644 --- a/lib/delayed_job.rb +++ b/lib/delayed_job.rb @@ -8,5 +8,5 @@ Object.send(:include, Delayed::MessageSending) if defined?(Merb::Plugins) - Merb::Plugins.add_rakefiles File.dirname(__FILE__) / '..' / 'tasks' / 'merbtasks' + Merb::Plugins.add_rakefiles File.dirname(__FILE__) / '..' / 'tasks' / 'tasks' end diff --git a/tasks/jobs.rake b/tasks/jobs.rake index d7f0b8cea..9579ecdea 100644 --- a/tasks/jobs.rake +++ b/tasks/jobs.rake @@ -1,11 +1 @@ -namespace :jobs do - desc "Clear the delayed_job queue." - task :clear => :environment do - Delayed::Job.delete_all - end - - desc "Start a delayed_job worker." - task :work => :environment do - Delayed::Worker.new(:min_priority => ENV['MIN_PRIORITY'], :max_priority => ENV['MAX_PRIORITY']).start - end -end +load 'tasks' \ No newline at end of file diff --git a/tasks/merbtasks.rb b/tasks/tasks.rb similarity index 58% rename from tasks/merbtasks.rb rename to tasks/tasks.rb index 1e6490f08..b62fbd850 100644 --- a/tasks/merbtasks.rb +++ b/tasks/tasks.rb @@ -1,11 +1,15 @@ +# Re-definitions are appended to existing tasks +task :environment +task :merb_env + namespace :jobs do desc "Clear the delayed_job queue." - task :clear => :merb_env do + task :clear => [:merb_env, :environment] do Delayed::Job.delete_all end desc "Start a delayed_job worker." - task :work => :merb_env do + task :work => [:merb_env, :environment] do Delayed::Worker.new(:min_priority => ENV['MIN_PRIORITY'], :max_priority => ENV['MAX_PRIORITY']).start end end