Contents

module Taskinator
  class TaskWorker
    def initialize(uuid)
      @uuid = uuid
    end

    def perform
      task = Taskinator::Task.fetch(@uuid)
      return if task.paused? || task.cancelled?
      begin
        task.start!
        task.complete! if task.can_complete?
      rescue Exception => e
        Taskinator.logger.error(e)
        task.fail!(e)
        raise e
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
taskinator-0.0.15	lib/taskinator/task_worker.rb
taskinator-0.0.14	lib/taskinator/task_worker.rb
taskinator-0.0.13	lib/taskinator/task_worker.rb
taskinator-0.0.12	lib/taskinator/task_worker.rb
taskinator-0.0.11	lib/taskinator/task_worker.rb
taskinator-0.0.10	lib/taskinator/task_worker.rb
taskinator-0.0.9	lib/taskinator/task_worker.rb