Class: Fairy::Controller::MPInputProcessor

Inherits:
NjobMappingPolicy show all
Defined in:
lib/fairy/controller.rb

Instance Method Summary collapse

Methods inherited from NjobMappingPolicy

#initialize

Constructor Details

This class inherits a constructor from Fairy::Controller::NjobMappingPolicy

Instance Method Details

#assign_ntask(&block) ⇒ Object 



894
895
896
897
898
899
900
 
# File 'lib/fairy/controller.rb', line 894

def assign_ntask(&block)
  controller.assign_input_processor_n(target_bjob, 
 input_filter.host) do |processor|
    ntask = processor.create_ntask
    block.call(ntask, @mapper)
  end
end

#bind_input(njob) ⇒ Object 



902
903
904
905
906
907
908
 
# File 'lib/fairy/controller.rb', line 902

def bind_input(njob)
  begin
    njob.open(input_filter)
  rescue
    raise AbortCreateNode
  end
end