cli.cumanage Namespace Reference

Classes
class	CUManageCommand

Functions
def	task_exit_code (client, cluster, task_arns)
def	run_cumanage_task (stack, proxyargs, wait_until_complete=False, passphrase=None)

Detailed Description

Run cumanage operations in an AWS hosted stack.

Function Documentation

run_cumanage_task()

def cli.cumanage.run_cumanage_task	(		stack,
			proxyargs,
			wait_until_complete = False,
			passphrase = None
	)

Submit and run cumanage

Definition at line 57 of file cumanage.py.

def run_cumanage_task(stack,
                      proxyargs,
                      wait_until_complete=False,
                      passphrase=None):
    '''Submit and run cumanage'''
    if passphrase is None:
        passphrase = ''
    client = boto3.client('ecs', region_name=stack.region)
    taskdef = 'odyssey-%s-cumanage-tool' % stack.name
    shellish.vtmlprint("<b>Submitting:</b> <blue>%s</blue>" %
                       ' '.join(proxyargs))
    overrides = {
        "containerOverrides": [{
            "name": "cumanage",
            "command": proxyargs
        }]
    }
    response = client.run_task(cluster=stack.cluster,
                               taskDefinition=taskdef,
                               overrides=overrides)
    stack.save('Ran cumanage: %s' % ' '.join(proxyargs), passphrase)
    if wait_until_complete:
        task_arns = [x['taskArn'] for x in response['tasks']]
        waiter = client.get_waiter('tasks_stopped')
        if waiter.wait(cluster=stack.cluster, tasks=task_arns):
            raise SystemExit('Task waiter timed out!')
        return task_exit_code(client, stack.cluster, task_arns)
    return 0

task_exit_code()

def cli.cumanage.task_exit_code	(		client,
			cluster,
			task_arns
	)

Check tasks exit codes on `cluster`

Definition at line 44 of file cumanage.py.

def task_exit_code(client, cluster, task_arns):
    '''Check tasks exit codes on `cluster`'''
    response = client.describe_tasks(cluster=cluster, tasks=task_arns)
    tasks = response['tasks']
    containers = [container for containers in (x['containers'] for x in tasks)
                  for container in containers]
    exit_codes = [x.get('exitCode', -1) for x in containers]
    for code in exit_codes:
        if code != 0:
            return code
    return 0