Renamed Tracker to Workload Generator (#185) (#205)

* Renamed Tracker to Workload_Processor Signed-off-by: Ian Hoang <hoangia@amazon.com> * Update import in test_index.py to adhere to pylint standards Signed-off-by: Ian Hoang <hoangia@amazon.com> * Rename workload_processor to workload_generator to be more apt Signed-off-by: Ian Hoang <hoangia@amazon.com> Signed-off-by: Ian Hoang <hoangia@amazon.com> Co-authored-by: Ian Hoang <hoangia@amazon.com>
opensearch-project · Aug 11, 2022 · 589bcfd · 589bcfd
1 parent bc28461
commit 589bcfd
Show file tree

Hide file tree

Showing 8 changed files with 8 additions and 5 deletions.
diff --git a/osbenchmark/benchmark.py b/osbenchmark/benchmark.py
@@ -38,7 +38,7 @@
     test_execution_orchestrator, results_publisher, \
         metrics, workload, chart_generator, exceptions, log
 from osbenchmark.builder import provision_config, builder
-from osbenchmark.tracker import tracker
+from osbenchmark.workload_generator import workload_generator
 from osbenchmark.utils import io, convert, process, console, net, opts, versions
 
 
@@ -902,7 +902,7 @@ def dispatch_sub_command(arg_parser, args, cfg):
             cfg.add(config.Scope.applicationOverride, "workload", "workload.name", args.workload)
             configure_connection_params(arg_parser, args, cfg)
 
-            tracker.create_workload(cfg)
+            workload_generator.create_workload(cfg)
         elif sub_command == "info":
             configure_workload_params(arg_parser, args, cfg)
             workload.workload_info(cfg)

diff --git a/osbenchmark/tracker/__init__.py → osbenchmark/workload_generator/__init__.py b/osbenchmark/tracker/__init__.py → osbenchmark/workload_generator/__init__.py
diff --git a/osbenchmark/tracker/corpus.py → osbenchmark/workload_generator/corpus.py b/osbenchmark/tracker/corpus.py → osbenchmark/workload_generator/corpus.py
diff --git a/osbenchmark/tracker/index.py → osbenchmark/workload_generator/index.py b/osbenchmark/tracker/index.py → osbenchmark/workload_generator/index.py
diff --git a/osbenchmark/tracker/tracker.py → .../workload_generator/workload_generator.py b/osbenchmark/tracker/tracker.py → .../workload_generator/workload_generator.py
@@ -30,7 +30,7 @@
 
 from osbenchmark import PROGRAM_NAME
 from osbenchmark.client import OsClientFactory
-from osbenchmark.tracker import corpus, index
+from osbenchmark.workload_generator import corpus, index
 from osbenchmark.utils import io, opts, console
 
 

diff --git a/tests/tracker/__init__.py → tests/workload_generator/__init__.py b/tests/tracker/__init__.py → tests/workload_generator/__init__.py
diff --git a/tests/tracker/corpus_test.py → tests/workload_generator/corpus_test.py b/tests/tracker/corpus_test.py → tests/workload_generator/corpus_test.py
@@ -25,7 +25,7 @@
 from unittest import mock
 from unittest.mock import call
 
-from osbenchmark.tracker import corpus
+from osbenchmark.workload_generator import corpus
 
 
 def serialize_doc(doc):

diff --git a/tests/tracker/index_test.py → tests/workload_generator/index_test.py b/tests/tracker/index_test.py → tests/workload_generator/index_test.py
@@ -23,7 +23,10 @@
 # under the License.
 
 from unittest import mock
-from osbenchmark.tracker.index import filter_ephemeral_index_settings, extract_index_mapping_and_settings, update_index_setting_parameters
+from osbenchmark.workload_generator.index import (
+    filter_ephemeral_index_settings,
+    extract_index_mapping_and_settings,
+    update_index_setting_parameters)
 
 
 def test_index_setting_filter():