coordinating-ecs-master-v1.py

def master(filename, bucket, cluster, task, securityGroup, vpcSubnet, queue):
    pipeline = Pipeline(name=filename, steps=[
        EcsTask(cluster=cluster, task=task, securityGroup=securityGroup, vpcSubnet=vpcSubnet, queue=queue, environment=lambda token: [
            { 'name': 'TYPE', 'value': 'worker' },
            { 'name': 'FILENAME', 'value': filename },
            { 'name': 'BUCKET', 'value': bucket },
            { 'name': 'HOST', 'value': token['Host'] },
            { 'name': 'DIRECTORY', 'value': token['Directory'] },
        ])
    ])

    pipeline.start(input=filename)