lib/elasticity/job_flow.rb in elasticity-6.0.8 vs lib/elasticity/job_flow.rb in elasticity-6.0.9
- old
+ new
@@ -131,9 +131,21 @@
def set_task_instance_group(instance_group)
instance_group.role = 'TASK'
@instance_groups[:task] = instance_group
end
+ def set_master_ebs_configuration(ebs_configuration)
+ @instance_groups[:master].set_ebs_configuration(ebs_configuration)
+ end
+
+ def set_core_ebs_configuration(ebs_configuration)
+ @instance_groups[:core].set_ebs_configuration(ebs_configuration)
+ end
+
+ def set_task_ebs_configuration(ebs_configuration)
+ @instance_groups[:task].set_ebs_configuration(ebs_configuration)
+ end
+
def add_step(jobflow_step)
if is_jobflow_running?
jobflow_steps = []
if jobflow_step.requires_installation? && !@installed_steps.include?(jobflow_step.class)
jobflow_steps.concat(jobflow_step.aws_installation_steps)