#NEWLINE# @ classmethod #NEWLINE# def arguments_processor( cls , etl , input_args ) : #NEWLINE# #INDENT# 'Parse the step arguments according to the ETL pipeline\n\n        Args:\n            etl(ETLPipeline): Pipeline object containing resources and steps\n            step_args(dict): Dictionary of the step arguments for the class\n        ' #NEWLINE# if ( input_args . pop ( 'resource_type' , None ) == const . EMR_CLUSTER_STR ) : #NEWLINE# #INDENT# resource_type = const . EMR_CLUSTER_STR #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# resource_type = const . EC2_RESOURCE_STR #NEWLINE# #UNINDENT# step_args = cls . base_arguments_processor ( cls , input_args , resource_type = resource_type ) #NEWLINE# return step_args