#NEWLINE# @ requires_boto_gte ( '2.8' ) #NEWLINE# @ mock_emr #NEWLINE# def test_create_job_flow_with_instance_groups( ) : #NEWLINE# #INDENT# conn = boto . connect_emr ( ) #NEWLINE# instance_groups = [ InstanceGroup ( 6 , 'TASK' , 'c1.medium' , 'SPOT' , 'spot-0.07' , '0.07' ) , InstanceGroup ( 6 , 'TASK' , 'c1.medium' , 'SPOT' , 'spot-0.07' , '0.07' ) ] #NEWLINE# job_id = conn . run_jobflow ( name = 'My jobflow' , log_uri = 's3://some_bucket/jobflow_logs' , steps = [ ] , instance_groups = instance_groups ) #NEWLINE# job_flow = conn . describe_jobflow ( job_flow ) #NEWLINE# int ( job_flow . instancecount ) . should . equal ( 12 ) #NEWLINE# instance_group = job_flow . instancegroups [ 0 ] #NEWLINE# int ( instance_group . instancerunningcount ) . should . equal ( 6 )