def _UpdateTaskStatus()

in APIs/1.0/Common/task_management/distributed_api_task.py [0:0]

• 9 lines of code
• 2 McCabe index (conditional complexity)

    def _UpdateTaskStatus(self, taskId, status, backendStatus):
        old_stat = self.GetTaskStatus(taskId)
        endpoint = 'http://localhost'
        if not old_stat['Endpoint']:
            print("Cannot find task status. Creating")
        else:
            endpoint = old_stat['Endpoint']

        ret = asyncio.get_event_loop().run_until_complete(self._UpdateTaskStatusAsync(taskId, status, backendStatus, endpoint))
        return json.loads(ret)