Contents

class Step
  def archived_info
    return {} unless Open.exists?(info_file)
    info[:archived_info] || {}
  end

  def archived_inputs
    return [] unless info[:archived_dependencies]
    archived_info = self.archived_info

    all_inputs = NamedArray.setup([],[])
    deps = info[:archived_dependencies].dup
    seen = []
    while path = deps.pop
      dep_info = archived_info[path]
      if Hash === dep_info
        dep_inputs = dep_info[:inputs]
        NamedArray.setup(dep_inputs, dep_info[:input_names])
        all_inputs.concat(dep_inputs)
        deps.concat(dep_info[:dependencies].collect{|p| p.last } - seen) if dep_info[:dependencies]
        deps.concat(dep_info[:archived_dependencies].collect{|p| p.last } - seen) if dep_info[:archived_dependencies]
      end
      seen << path
    end

    all_inputs
  end

  def archive_deps(jobs = nil)
    jobs = dependencies if jobs.nil?

    archived_info = jobs.inject({}) do |acc,dep|
      next acc unless Open.exists?(dep.info_file)
      acc[dep.path] = dep.info
      acc.merge!(dep.archived_info)
      acc
    end

    self.set_info :archived_info, archived_info
    self.set_info :archived_dependencies, info[:dependencies]
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
scout-gear-10.7.3	lib/scout/workflow/step/archive.rb
scout-gear-10.7.2	lib/scout/workflow/step/archive.rb
scout-gear-10.7.1	lib/scout/workflow/step/archive.rb
scout-gear-10.7.0	lib/scout/workflow/step/archive.rb