INNER CODE UNIT · Python

aws_emr_step

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

    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)
            
    def aws_run(self, cmd):
        if (self.noop):
            click.echo("Noop! Cmd is: %s" % cmd)
        else:
            self.debug("Running: %s" % cmd)

View source record →