fixed runner and runner_test errors and now correctly works.

opensearch-project · Nov 2, 2023 · c6b6565 · c6b6565
1 parent 7ec47c3
commit c6b6565
Show file tree

Hide file tree

Showing 2 changed files with 251 additions and 273 deletions.
diff --git a/osbenchmark/worker_coordinator/runner.py b/osbenchmark/worker_coordinator/runner.py
@@ -1101,7 +1101,7 @@ async def __call__(self, opensearch, params):
                                      )
 
     def __repr__(self, *args, **kwargs):
-        return "create-ingest-pipeline"
+        return opensearch.ingest.put_pipeline.return_value = as_future()
 
 # TODO: refactor it after python client support search pipeline https://github.com/opensearch-project/opensearch-py/issues/474
 class CreateSearchPipeline(Runner):