Contents

module Rivendell::Import
  class Tasks

    def pop
      Task.pending.first
    end

    def run
      Task.pending.find_each(&:run)
    end

    def create(file, &block)
      Rivendell::Import::Task.create({:file => file}, {}, &block).tap do |task|
        Rivendell::Import.logger.debug "Created task #{task.inspect}"
      end
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
rivendell-import-0.0.5	lib/rivendell/import/tasks.rb
rivendell-import-0.0.4	lib/rivendell/import/tasks.rb
rivendell-import-0.0.3	lib/rivendell/import/tasks.rb
rivendell-import-0.0.2	lib/rivendell/import/tasks.rb