formatting

Author: milindsrivastava1997

asap-tools/experiments/experiment_utils/services/arroyo.py

@@ -65,7 +65,9 @@ def stop(self, **kwargs) -> None:
     def stop_all_jobs(self) -> None:
         """Stop all running Arroyo jobs."""
         cmd = "python3 delete_pipeline.py --all_pipelines"
-        cmd_dir = os.path.join(self.provider.get_home_dir(), "code", "asap-sketch-ingest")
+        cmd_dir = os.path.join(
+            self.provider.get_home_dir(), "code", "asap-sketch-ingest"
+        )
         self.provider.execute_command(
             node_idx=self.node_offset,
             cmd=cmd,
@@ -157,7 +159,9 @@ def run_arroyosketch(
             # Add optimized source flag if enabled
             if enable_optimized_remote_write:
                 cmd += " --prometheus_remote_write_source optimized"
-        cmd_dir = os.path.join(constants.CLOUDLAB_HOME_DIR, "code", "asap-sketch-ingest")
+        cmd_dir = os.path.join(
+            constants.CLOUDLAB_HOME_DIR, "code", "asap-sketch-ingest"
+        )
 
         if avoid_long_ssh:
             # Run in background to avoid long SSH connection
@@ -211,7 +215,9 @@ def stop_arroyosketch(self, pipeline_id: str) -> None:
             pipeline_id: ID of the pipeline to stop
         """
         cmd = "python3 delete_pipeline.py --pipeline_id {}".format(pipeline_id)
-        cmd_dir = os.path.join(constants.CLOUDLAB_HOME_DIR, "code", "asap-sketch-ingest")
+        cmd_dir = os.path.join(
+            constants.CLOUDLAB_HOME_DIR, "code", "asap-sketch-ingest"
+        )
         self.provider.execute_command(
             node_idx=self.node_offset,
             cmd=cmd,

asap-tools/experiments/experiment_utils/services/prometheus_client_service.py

@@ -171,7 +171,9 @@ def _start_bare_metal(
         if profile_prometheus_time is not None:
             cmd += " --profile_prometheus_time {}".format(profile_prometheus_time)
 
-        cmd_dir = os.path.join(self.provider.get_home_dir(), "code", "asap-tools", "prometheus-client")
+        cmd_dir = os.path.join(
+            self.provider.get_home_dir(), "code", "asap-tools", "prometheus-client"
+        )
         utils.run_cmd(f"cd {cmd_dir}; {cmd}", popen=False)
 
         return

asap-tools/experiments/experiment_utils/services/query_engine.py

@@ -551,7 +551,9 @@ def _start_bare_metal(
             cmd += "--dump-precomputes "
         cmd += "> {}/query_engine_rust.out 2>&1 &".format(output_dir)
 
-        cmd_dir = os.path.join(self.provider.get_home_dir(), "code", "asap-query-engine")
+        cmd_dir = os.path.join(
+            self.provider.get_home_dir(), "code", "asap-query-engine"
+        )
         self.provider.execute_command(
             node_idx=self.node_offset,
             cmd=cmd,