From: smahana123 <s.mahana@samsung.com>
Date: Mon, 12 Dec 2022 13:39:58 +0000 (+0530)
Subject: BugFix Revert.
X-Git-Tag: 1.0.0~3
X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=commitdiff_plain;h=306a89ba72b0f861c26bf66019cb64e2fd6e8540;p=aiml-fw%2Fawmf%2Ftm.git

BugFix Revert.

Issue-Id: AIMLFW-6

Signed-off-by: smahana123 <s.mahana@samsung.com>
Change-Id: I18f35369f744ac41315c72002ba2a073cd4630df
---

diff --git a/trainingmgr/common/trainingmgr_operations.py b/trainingmgr/common/trainingmgr_operations.py
index a258f1a..29a626b 100644
--- a/trainingmgr/common/trainingmgr_operations.py
+++ b/trainingmgr/common/trainingmgr_operations.py
@@ -24,7 +24,6 @@ Training manager main operations
 import json
 import requests
 
-str_ing = 'http://'
 def data_extraction_start(training_config_obj, trainingjob_name, feature_list, query_filter,
                           datalake_source, _measurement, bucket):
     """
@@ -35,7 +34,7 @@ def data_extraction_start(training_config_obj, trainingjob_name, feature_list, q
     logger.debug('training manager is calling data extraction for '+trainingjob_name)
     data_extraction_ip = training_config_obj.data_extraction_ip
     data_extraction_port = training_config_obj.data_extraction_port
-    url = str_ing+str(data_extraction_ip)+':'+str(data_extraction_port)+'/feature-groups'
+    url = 'http://'+str(data_extraction_ip)+':'+str(data_extraction_port)+'/feature-groups'
     logger.debug(url)
 
     source = {}
@@ -85,7 +84,7 @@ def data_extraction_status(trainingjob_name,training_config_obj):
     logger.debug('training manager is calling data extraction for '+trainingjob_name)
     data_extraction_ip = training_config_obj.data_extraction_ip
     data_extraction_port = training_config_obj.data_extraction_port
-    url = str_ing+str(data_extraction_ip)+':'+str(data_extraction_port)+\
+    url = 'http://'+str(data_extraction_ip)+':'+str(data_extraction_port)+\
           '/task-status/'+trainingjob_name
     logger.debug(url)
     response = requests.get(url)
@@ -101,7 +100,7 @@ def training_start(training_config_obj, dict_data, trainingjob_name):
     logger.debug('training manager will send to kf_adapter: '+json.dumps(dict_data))
     kf_adapter_ip = training_config_obj.kf_adapter_ip
     kf_adapter_port = training_config_obj.kf_adapter_port
-    url = str_ing+str(kf_adapter_ip)+':'+str(kf_adapter_port)+\
+    url = 'http://'+str(kf_adapter_ip)+':'+str(kf_adapter_port)+\
             '/trainingjobs/' + trainingjob_name + '/execution'
     logger.debug(url)
     response = requests.post(url,