#NEWLINE# def run_job_flow( self , name , log_uri , job_flow_role , visible_to_all_users , steps , instance_attrs ) : #NEWLINE# #INDENT# job_id = random_job_id ( ) #NEWLINE# job_flow = FakeJobFlow ( job_id , name , log_uri , job_flow_role , visible_to_all_users , steps , instance_attrs , self ) #NEWLINE# self . job_flows [ job_id ] = job_flow #NEWLINE# cluster = job_flow . create_cluster ( ) #NEWLINE# self . clusters [ cluster . id ] = cluster #NEWLINE# return job_flow