def AddPipelineTask()

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

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

    def AddPipelineTask(self, taskId, organization_moniker, version, api_name, body):
        old_stat = self.GetTaskStatus(taskId)
        if old_stat['Status'] == "not found":
            print("Cannot find task status.")
            return json.loads('{"TaskId": "-1", "Status": "error"}')
        
        parsed_endpoint = urlparse(old_stat['Endpoint'])
        path = '{}/{}/{}'.format(version, organization_moniker, api_name)
        next_endpoint = '{}://{}/{}'.format(parsed_endpoint.scheme, parsed_endpoint.netloc, path)

        print("Sending to next endpoint: " + next_endpoint)

        asyncio.set_event_loop(asyncio.new_event_loop())
        ret = asyncio.get_event_loop().run_until_complete(self.AddPipelineTaskAsync(taskId, next_endpoint, body))
        return json.loads(ret)