def AddPipelineTask()

in Containers/Common/task_management/distributed_api_task.py [0:0]

• 23 lines of code
• 3 McCabe index (conditional complexity)

    def AddPipelineTask(self, taskId, organization_moniker, version, api_name, body):
        old_stat = self.GetTaskStatus(taskId)
        if old_stat == "not found":
            print("Cannot find task status.")
        
        parsed_endpoint = urlparse(old_stat['Endpoint'])

        next_endpoint = urlunparse(('http', parsed_endpoint.netloc, organization_moniker + '/' + version + '/' + api_name))
        print("Sending to next endpoint: " + next_endpoint)

        r = requests.post(self.cache_connector_upsert_url,
            data=json.dumps(
                {'Uuid': taskId, 
                'Timestamp': datetime.datetime.strftime(datetime.datetime.now(), "%Y-%m-%d %H:%M:%S"), 
                'Status': 'created', 
                'BackendStatus': 'created',
                'Endpoint': next_endpoint,
                'Body': body,
                'PublishToGrid': True
                })
            )

        if r.status_code != 200:
            print("status code: " + str(r.status_code))
            return -1
        else:
            return r.json()