kanfet

# Custom tasks based on https://gist.github.com/bkutil/1431483

require 'resque/tasks'
require 'resque/scheduler/tasks'

# Start a worker with proper env vars and output redirection
def run_worker(queue, worker_number)
  puts "Starting worker with QUEUE: #{queue}"
  ops = {:pgroup => true, :err => [(Rails.root + 'log/resque_workers_error.log').to_s, 'a'],
         :out => [(Rails.root + 'log/resque_workers.log').to_s, 'a']}