Modify rally to allow multiple cars with complex configuration

.pre-commit-config.yaml

@@ -22,7 +22,13 @@ repos:
     rev: v1.6.1
     hooks:
       - id: mypy
+        additional_dependencies: [
+          "elasticsearch[async]==8.6.1",
+          "elastic-transport==8.4.1",
+          "types-tabulate==0.8.9",
+        ]
         args: [
+          "--ignore-missing-imports",
           "--config",
           "pyproject.toml"
         ]

esrally/client/asynchronous.py

@@ -77,7 +77,7 @@ async def send(self, conn: "Connection") -> "ClientResponse":
         self.response = self.response_class(
             self.method,
             self.original_url,
-            writer=self._writer,
+            writer=self._writer,  # type: ignore[arg-type]  # TODO remove this ignore when introducing type hints
             continue100=self._continue,
             timer=self._timer,
             request_info=self.request_info,
@@ -223,7 +223,7 @@ def __init__(self, config):
         self._loop = None
         self.client_id = None
         self.trace_configs = None
-        self.enable_cleanup_closed = None
+        self.enable_cleanup_closed = False
         self._static_responses = None
         self._request_class = aiohttp.ClientRequest
         self._response_class = aiohttp.ClientResponse

esrally/mechanic/launcher.py

@@ -242,7 +242,7 @@ def stop(self, nodes, metrics_store):
                 stop_watch.start()
                 try:
                     es.terminate()
-                    es.wait(10.0)
+                    es.wait(10)
                     stopped_nodes.append(node)
                 except psutil.NoSuchProcess:
                     self.logger.warning("No process found with PID [%s] for node [%s].", es.pid, node_name)