def submit_job(self, command, env={}, job_name=''):
    "Submits a new hpo trial to argo in order to start a workflow template\n\n        Args:\n            command (list[str]): List that contains ['Argo WorkflowTemplate','Entrypoint of that Argo WorkflowTemplate]\n            env (dict, optional): Dictionary that contains env variables, mainly the sherpa_trial_id. Defaults to {}.\n            job_name (str, optional): Not needed for Argo scheduler. Defaults to ''.\n\n        Returns:\n            [str]: Sherpa Job_ID / Name of the workflow that was started by Argo\n        "
    os.environ['SHERPA_TRIAL_ID'] = env['SHERPA_TRIAL_ID']
    trial = self.client.get_trial()
    tp = trial.parameters
    WorkflowTemplate = command[0]
    entrypoint = command[1]
    default_parameter = self.default_parameter
    if ('save_to' in tp):
        default_parameter['output_path'] = os.path.join(self.output_path, str(tp['save_to']), '')
    else:
        default_parameter['output_path'] = os.path.join(self.output_path, str(env['SHERPA_TRIAL_ID']), '')
    if (('load_from' in tp) and (tp['load_from'] != '')):
        default_parameter['model_input_path'] = os.path.join(self.output_path, str(tp['load_from']), '')
        WorkflowTemplate = eval(self.trial_run_parameter)['WorkflowTemplateContinue']
        entrypoint = eval(self.trial_run_parameter)['EntrypointContinue']
    else:
        default_parameter['model_input_path'] = ''
    merged_parameter = eval(self.trial_run_parameter)
    for (k, v) in default_parameter.items():
        merged_parameter[k] = v
    epochs = merged_parameter.get('epochs', 0)
    parameters_list = []
    for (key, val) in merged_parameter.items():
        parameters_list.append('{}={}'.format(key, val))
    data = json.dumps({'resourceKind': 'WorkflowTemplate', 'resourceName': WorkflowTemplate, 'submitOptions': {'entrypoint': entrypoint, 'labels': ((('sherpa_run=' + self.hostname) + ',run_name=') + self.run_name), 'parameters': parameters_list}})
    response_submit = self.make_request(request='POST', data=data)
    if (response_submit.status_code == 200):
        job_id = json.loads(response_submit.content)['metadata']['name']
        logging.info('Submitted trial {} with job_id {}'.format(env['SHERPA_TRIAL_ID'], job_id))
    else:
        job_id = ('failed_trial_id_' + str(env['SHERPA_TRIAL_ID']))
        logging.warning('Failed to sumbit job with Trial_ID {} to argo.'.format(env['SHERPA_TRIAL_ID']))
    self.trials[job_id] = {'trial': trial, 'epochs': epochs, 'output_path': default_parameter['output_path'], 'model_input_path': default_parameter['model_input_path'], 'status': 0, 'finished': False}
    return job_id
Submits a new hpo trial to argo in order to start a workflow template

Args:
    command (list[str]): List that contains ['Argo WorkflowTemplate','Entrypoint of that Argo WorkflowTemplate]
    env (dict, optional): Dictionary that contains env variables, mainly the sherpa_trial_id. Defaults to {}.
    job_name (str, optional): Not needed for Argo scheduler. Defaults to ''.

Returns:
    [str]: Sherpa Job_ID / Name of the workflow that was started by Argo
def submit_job(self, command, env={}, job_name=):
    "Submits a new hpo trial to argo in order to start a workflow template\n\n        Args:\n            command (list[str]): List that contains ['Argo WorkflowTemplate','Entrypoint of that Argo WorkflowTemplate]\n            env (dict, optional): Dictionary that contains env variables, mainly the sherpa_trial_id. Defaults to {}.\n            job_name (str, optional): Not needed for Argo scheduler. Defaults to .\n\n        Returns:\n            [str]: Sherpa Job_ID / Name of the workflow that was started by Argo\n        "
    os.environ['SHERPA_TRIAL_ID'] = env['SHERPA_TRIAL_ID']
    trial = self.client.get_trial()
    tp = trial.parameters
    WorkflowTemplate = command[0]
    entrypoint = command[1]
    default_parameter = self.default_parameter
    if ('save_to' in tp):
        default_parameter['output_path'] = os.path.join(self.output_path, str(tp['save_to']), )
    else:
        default_parameter['output_path'] = os.path.join(self.output_path, str(env['SHERPA_TRIAL_ID']), )
    if (('load_from' in tp) and (tp['load_from'] != )):
        default_parameter['model_input_path'] = os.path.join(self.output_path, str(tp['load_from']), )
        WorkflowTemplate = eval(self.trial_run_parameter)['WorkflowTemplateContinue']
        entrypoint = eval(self.trial_run_parameter)['EntrypointContinue']
    else:
        default_parameter['model_input_path'] = 
    merged_parameter = eval(self.trial_run_parameter)
    for (k, v) in default_parameter.items():
        merged_parameter[k] = v
    epochs = merged_parameter.get('epochs', 0)
    parameters_list = []
    for (key, val) in merged_parameter.items():
        parameters_list.append('{}={}'.format(key, val))
    data = json.dumps({'resourceKind': 'WorkflowTemplate', 'resourceName': WorkflowTemplate, 'submitOptions': {'entrypoint': entrypoint, 'labels': ((('sherpa_run=' + self.hostname) + ',run_name=') + self.run_name), 'parameters': parameters_list}})
    response_submit = self.make_request(request='POST', data=data)
    if (response_submit.status_code == 200):
        job_id = json.loads(response_submit.content)['metadata']['name']
        logging.info('Submitted trial {} with job_id {}'.format(env['SHERPA_TRIAL_ID'], job_id))
    else:
        job_id = ('failed_trial_id_' + str(env['SHERPA_TRIAL_ID']))
        logging.warning('Failed to sumbit job with Trial_ID {} to argo.'.format(env['SHERPA_TRIAL_ID']))
    self.trials[job_id] = {'trial': trial, 'epochs': epochs, 'output_path': default_parameter['output_path'], 'model_input_path': default_parameter['model_input_path'], 'status': 0, 'finished': False}
    return job_id