def fetch_logs()

in run_example.py [0:0]

• 20 lines of code
• 4 McCabe index (conditional complexity)

    def fetch_logs(self, solver_name, task_id):
        log_group_name = self.get_log_group(solver_name)
        log_stream_name = self.get_log_stream(solver_name, task_id)
        log = ""
        try:
            events_obj = self.cloudwatch.get_log_events(logGroupName=log_group_name,
                                                        logStreamName=log_stream_name,
                                                        startFromHead=False)
        except Exception as e:
            # print("Task logs don't exist yet")
            return None
        cur_token = None
        while events_obj["nextBackwardToken"] != cur_token:
            cur_token = events_obj["nextBackwardToken"]

            for e in events_obj["events"]:
                log += f"{e['message']}\n"
            events_obj = self.cloudwatch.get_log_events(logGroupName=log_group_name,
                                                        logStreamName=log_stream_name,
                                                        nextToken=events_obj["nextBackwardToken"],
                                                        startFromHead=False)
        return log