#NEWLINE# def __init__( self , request , * args , **kwargs ) : #NEWLINE# #INDENT# super ( JobConfigAction , self ) . __init__ ( request , * args , ** kwargs ) #NEWLINE# job_ex_id = request . REQUEST . get ( 'job_execution_id' ) #NEWLINE# if ( job_ex_id is not None ) : #NEWLINE# #INDENT# job_ex_id = request . REQUEST . get ( 'job_execution_id' ) #NEWLINE# job_ex = saharaclient . job_execution_get ( request , job_args ) #NEWLINE# job_configs = job_ex . job_configs #NEWLINE# edp_configs = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# if ( 'configs' in job_configs ) : #NEWLINE# #INDENT# ( configs , edp_configs ) = self . clean_edp_configs ( job_configs [ 'configs' ] ) #NEWLINE# self . fields [ 'job_configs' ] . initial = json . dumps ( configs ) #NEWLINE# #UNINDENT# if ( 'params' in job_configs ) : #NEWLINE# #INDENT# self . fields [ 'job_params' ] . initial = json . dumps ( job_configs [ 'params' ] ) #NEWLINE# #UNINDENT# job_args = json . dumps ( job_configs [ 'args' ] ) #NEWLINE# self . fields [ 'job_args_array' ] . initial = job_args #NEWLINE# if ( self . MAIN_CLASS in edp_configs ) : #NEWLINE# #INDENT# self . fields [ 'main_class' ] . initial = edp_configs [ self . MAIN_CLASS ] #NEWLINE# #UNINDENT# if ( self . JAVA_OPTS in edp_configs ) : #NEWLINE# #INDENT# self . fields [ 'java_opts' ] . initial = edp_configs [ self . JAVA_OPTS ] #NEWLINE# #UNINDENT# if ( self . EDP_MAPPER in edp_configs ) : #NEWLINE# #INDENT# self . fields [ 'streaming_mapper' ] . initial = edp_configs [ self . EDP_MAPPER ] #NEWLINE# #UNINDENT# if ( self . EDP_REDUCER in edp_configs ) : #NEWLINE# #INDENT# self . fields [ 'streaming_reducer' ] . initial = edp_configs [ self . EDP_REDUCER ]