Modify rally to allow multiple cars with complex configuration

.pre-commit-config.yaml

@@ -9,7 +9,7 @@ repos:
         ]
 
   - repo: https://github.com/psf/black
-    rev: 23.3.0
+    rev: 24.4.2
     hooks:
       - id: black
 
@@ -18,10 +18,13 @@ repos:
     hooks:
       - id: isort
 
-  - repo: https://github.com/pre-commit/mirrors-mypy
-    rev: v1.6.1
+  - repo: local
     hooks:
       - id: mypy
+        name: mypy
+        entry: mypy
+        language: system
+        types: [python]
         args: [
           "--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/driver/scheduler.py

@@ -166,8 +166,7 @@ def remove_scheduler(name):
 
 class SimpleScheduler(ABC):
     @abstractmethod
-    def next(self, current):
-        ...
+    def next(self, current): ...
 
 
 class Scheduler(ABC):
@@ -178,8 +177,7 @@ def after_request(self, now, weight, unit, request_meta_data):
         pass
 
     @abstractmethod
-    def next(self, current):
-        ...
+    def next(self, current): ...
 
 
 # Deprecated

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)