X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?p=bottlenecks.git;a=blobdiff_plain;f=test-scheduler%2Fserver%2Fsrc%2Fstep%2Fworkload.py;fp=testing-scheduler%2Fserver%2Fsrc%2Fstep%2Fworkload.py;h=b35819e1e3e13164d942566270e6d2a90d76b8f5;hp=265b9a6bffdbbb94b6abe91a740b5c8471e4a721;hb=e32043f58a2450b6a5986dc2a01f64f8b22c3992;hpb=a09bbea983aca3e437e254566da98196177748d9

diff --git a/testing-scheduler/server/src/step/workload.py b/test-scheduler/server/src/step/workload.py
similarity index 97%
rename from testing-scheduler/server/src/step/workload.py
rename to test-scheduler/server/src/step/workload.py
index 265b9a6b..b35819e1 100644
--- a/testing-scheduler/server/src/step/workload.py
+++ b/test-scheduler/server/src/step/workload.py
@@ -1,46 +1,46 @@
-##############################################################################
-# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.
-#
-# All rights reserved. This program and the accompanying materials
-# are made available under the terms of the Apache License, Version 2.0
-# which accompanies this distribution, and is available at
-# http://www.apache.org/licenses/LICENSE-2.0
-##############################################################################
-
-import json
-import os
-from src.step.test_step import TestStep
-
-
-class WorkloadStep(TestStep):
-    __step_type__ = 'workload'
-
-    def __init__(self, id, name, service, action, args):
-        super(WorkloadStep, self).__init__(
-            self.__step_type__, id, name, service, action, args)
-        self._argsParse()
-        self._action()
-
-    def _argsParse(self):
-        if self._callType == "REST":
-            currentDirPath = os.path.dirname(os.path.abspath(__file__))
-            envDirPath = os.path.abspath(
-                os.path.join(currentDirPath, os.pardir, os.pardir, 'env'))
-            envFilePath = os.path.join(
-                envDirPath, "%s.json" % self._service['name'])
-            with open(envFilePath) as f:
-                propDict = json.load(f)
-                self._args['ip'] = propDict['ip']
-                self._args['port'] = propDict['port']
-                self._args['api'] = "%s/%s" % (
-                    propDict['api_map']['workload'], self._args['command'])
-                exclude = {'ip', 'port', 'api', 'command', 'method'}
-                self._args['req_body'] = {
-                    key: value for key, value in
-                    self._args.items() if key not in exclude}
-
-    def _start(self):
-        print "workload start"
-
-    def _stop(self):
-        print "workload stop"
+##############################################################################
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.
+#
+# All rights reserved. This program and the accompanying materials
+# are made available under the terms of the Apache License, Version 2.0
+# which accompanies this distribution, and is available at
+# http://www.apache.org/licenses/LICENSE-2.0
+##############################################################################
+
+import json
+import os
+from src.step.test_step import TestStep
+
+
+class WorkloadStep(TestStep):
+    __step_type__ = 'workload'
+
+    def __init__(self, id, name, service, action, args):
+        super(WorkloadStep, self).__init__(
+            self.__step_type__, id, name, service, action, args)
+        self._argsParse()
+        self._action()
+
+    def _argsParse(self):
+        if self._callType == "REST":
+            currentDirPath = os.path.dirname(os.path.abspath(__file__))
+            envDirPath = os.path.abspath(
+                os.path.join(currentDirPath, os.pardir, os.pardir, 'env'))
+            envFilePath = os.path.join(
+                envDirPath, "%s.json" % self._service['name'])
+            with open(envFilePath) as f:
+                propDict = json.load(f)
+                self._args['ip'] = propDict['ip']
+                self._args['port'] = propDict['port']
+                self._args['api'] = "%s/%s" % (
+                    propDict['api_map']['workload'], self._args['command'])
+                exclude = {'ip', 'port', 'api', 'command', 'method'}
+                self._args['req_body'] = {
+                    key: value for key, value in
+                    self._args.items() if key not in exclude}
+
+    def _start(self):
+        print "workload start"
+
+    def _stop(self):
+        print "workload stop"