INNER CODE UNIT · Python

AWSContext

aehrc/VariantSpark · cloud/aws-emr/python/vs_emr/cli.py:26

class AWSContext(object):
    def __init__(self, noop = False, verbose = False, silent = False):
        self.noop = noop
        self.verbose = verbose
        self.silent = silent
    
    def aws_emr_step(self, cluster_id, step_name, action_on_failure, args):
        output =  self.aws_run(EMR_TEMPL % dict(cluster_id = cluster_id, step_name = step_name,
                    action_on_failure = action_on_failure , arg_list = ",".join(args)))
        return output and json.loads(output)['StepIds'][0] 
    
    def echo(self, msg):
        if not self.silent:
            click.echo(msg)
            
    def debug(self, msg):
        if self.verbose:
            self.echo(msg)

View source record →