in run_example.py [0:0]
def task_completed(self): described = self.ecs_client.describe_tasks(cluster=self.cluster_name, tasks=[self.task_arn])["tasks"][0] return described['lastStatus'] == "STOPPED"