flow.run_config = ECSRun(
        env={
            "S3_ENDPOINT_URL": os.getenv('S3_ENDPOINT_URL'),
            "AWS_ACCESS_KEY_ID": os.getenv('AWS_ACCESS_KEY_ID'),
            "AWS_SECRET_ACCESS_KEY": os.getenv('AWS_SECRET_ACCESS_KEY'),
            "AWS_DEFAULT_REGION": os.getenv('AWS_DEFAULT_REGION')
        },
        execution_role_arn=os.getenv('EXECUTION_ROLE_ARN'),
        task_definition={
            'containerDefinitions': [
                {
                    'name': 'flow',
                    'image': os.getenv('FLOW_IMAGE')
                }
            ]
        }
    )

    <http://logging.info|logging.info>('Created flow')
    flow.register(project_name=PROJECT_NAME, labels=[LABEL], add_default_labels=False)

    <http://logging.info|logging.info>('Creating Agent...')
    agent = ECSAgent(
        labels=[LABEL],
        task_role_arn=os.getenv('TASK_ROLE_ARN'),
        execution_role_arn=os.getenv('EXECUTION_ROLE_ARN'),
        cluster=os.getenv('CLUSTER_ID')
    )
    agent.start()