def _UpdateTaskStatus()

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

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

    def _UpdateTaskStatus(self, taskId, status, backendStatus):
        old_stat = self.GetTaskStatus(taskId)
        if old_stat == "not found":
            print("Cannot find task status.")
        
        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': status, 
                'BackendStatus': backendStatus,
                'Endpoint': old_stat['Endpoint'],
                'Body': old_stat['Body'],
                'PublishToGrid': False
                })
            )

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