def save_training_status()

in decisionai_plugin/common/tsanaclient.py [0:0]

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

    def save_training_status(self, task_id, parameters, status, last_error=None):
        try: 
            context = {}
            context['groupId'] = parameters['groupId']
            context['groupName'] = parameters['groupName']
            context['instanceId'] = parameters['instance']['instanceId']
            context['instanceName'] = parameters['instance']['instanceName']
            context['startTime'] = parameters['startTime']
            context['endTime'] = parameters['endTime']

            body = {
                'taskId': task_id,
                'operation': 'Train',
                'context': context,
                'status': status,
                'lastError': str(last_error)[:1000] if last_error is not None else ''
                }
               
            self.post(TSG_ENDPOINT if IS_INTERNAL else parameters['apiEndpointV2'] + TSG_API, parameters[INSTANCE_ID_KEY], parameters['apiKey'], parameters['groupId'] + USER_ADDR, '/timeSeriesGroups/' + parameters['groupId'] + '/appInstances/' + parameters['instance']['instanceId'] + '/ops', body)
            return STATUS_SUCCESS, ''
        except Exception as e:
            log.warning(f"Save training status failed. taskId: {task_id}, error: {str(e)}")
            return STATUS_FAIL, str(e)