in src/helper.py [0:0]
def ecs_run_task(**ecs_parameters):
"""Runs an ECS Task
Args:
ecs_parameters (dict): Data pass through from SQS to ECS run task
Returns:
N/A
"""
logger.info("Attempting to start ECS Task")
ecs = boto3.client('ecs')
response = ecs.run_task(**ecs_parameters)
logger.info(response)
# If received a failure within the response raise error
if len(response['failures']) > 0:
raise Exception(response['failures'][0]['reason'])
logger.info("Successfully started container using command:%s", ecs_parameters)