Class: Specwrk::CLI::Work

Inherits:
Dry::CLI::Command
  • Object
show all
Includes:
Clientable, HooksConfigurable, Workable
Defined in:
lib/specwrk/cli.rb

Constant Summary

Constants included from WorkerProcesses

Specwrk::CLI::WorkerProcesses::WORKER_INIT_SCRIPT

Instance Method Summary collapse

Methods included from Hookable

extended, #included, #included_hooks, #on_included, #on_setup, #setup_hooks

Methods included from WorkerProcesses

#drain_outputs, #start_workers, #worker_count, #worker_env_for

Instance Method Details

#call(**args) ⇒ Object 



229
230
231
232
233
234
235
236
237
238
239
240
 
# File 'lib/specwrk/cli.rb', line 229

def call(**args)
  self.class.setup(**args)

  start_workers
  wait_for_workers_exit
  drain_outputs

  require "specwrk/cli_reporter"
  Specwrk::CLIReporter.new.report

  exit(status)
end

#status ⇒ Object 



249
250
251
 
# File 'lib/specwrk/cli.rb', line 249

def status
  @exited_pids.value?(1) ? 1 : 0
end

#wait_for_workers_exit ⇒ Object 



242
243
244
245
246
247
 
# File 'lib/specwrk/cli.rb', line 242

def wait_for_workers_exit
  Specwrk.wait_for_pids_exit(@worker_pids).tap do |exited_pids|
    @exited_pids = exited_pids
    Hooks.run(:after_all_workers_exit, status)
  end
end