Contents

require_relative '../parallel_tests'
require 'tempfile'

module Zeus::ParallelTests
  class Worker
    def self.run(argv, env)
      dumped_argv = argv.dup
      new(dumped_argv.shift, env, dumped_argv).spawn
    end

    def self.command(suite)
      "ruby #{__FILE__} #{suite}"
    end

    def initialize(suite, env, argv)
      @env = env
      @argv = argv
      @suite = suite
    end

    def spawn
      system %{zeus parallel_#{@suite}_worker #{parallel_tests_attributes}}
      args_file.unlink
      $?.to_i
    end

    private

    def parallel_tests_attributes
      [test_env_number.to_s,
       @env['PARALLEL_TEST_GROUPS'],
       args_file.path].join(' ')
    end

    def args_file
      @args_file ||= begin
                       Tempfile.new("rspec_args").tap do |file|
                         @argv.each do |arg|
                           file.puts arg
                         end
                         file.close
                       end
                     end
    end

    def test_env_number
      @env['TEST_ENV_NUMBER'] != "" && @env['TEST_ENV_NUMBER'] || 1
    end
  end
end

if $PROGRAM_NAME == __FILE__
  exit Zeus::ParallelTests::Worker.run(ARGV, ENV)
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
zeus-parallel_tests-0.2.4	lib/zeus/parallel_tests/worker.rb
zeus-parallel_tests-0.2.3	lib/zeus/parallel_tests/worker.rb
zeus-parallel_tests-0.2.2	lib/zeus/parallel_tests/worker.rb
zeus-parallel_tests-0.2.1	lib/zeus/parallel_tests/worker.rb
zeus-parallel_tests-0.2.0	lib/zeus/parallel_tests/worker.rb