adding format fixes

Author: Saumya-R

feature_integration_tests/test_cases/lifecycle_scenario.py

@@ -43,9 +43,7 @@ def read_launch_manager_config(config_path: Path) -> dict[str, Any]:
     return json.loads(config_path.read_text())
 
 
-def create_launch_manager_config(
-    config_path: Path, components: dict[str, Any], run_targets: dict[str, Any]
-) -> Path:
+def create_launch_manager_config(config_path: Path, components: dict[str, Any], run_targets: dict[str, Any]) -> Path:
     """
     Create a launch manager configuration JSON file.
 
@@ -68,9 +66,7 @@ def create_launch_manager_config(
         "defaults": {
             "deployment_config": {
                 "bin_dir": "/tmp/lifecycle_test/bin/",
-                "ready_recovery_action": {
-                    "restart": {"number_of_attempts": 1, "delay_before_restart": 0.5}
-                },
+                "ready_recovery_action": {"restart": {"number_of_attempts": 1, "delay_before_restart": 0.5}},
                 "sandbox": {
                     "uid": 0,
                     "gid": 0,
@@ -90,9 +86,7 @@ def create_launch_manager_config(
             },
             "run_target": {
                 "transition_timeout": 5,
-                "recovery_action": {
-                    "switch_run_target": {"run_target": "fallback_run_target"}
-                },
+                "recovery_action": {"switch_run_target": {"run_target": "fallback_run_target"}},
             },
         },
         "components": components,

feature_integration_tests/test_cases/tests/lifecycle/test_dependency_ordering.py

@@ -72,16 +72,16 @@ def test_sequential_checkpoints_reported(
         if version == "cpp":
             # For C++ scenarios, check stdout directly
             for i in range(4):
-                assert f"Reported checkpoint init_step_{i} in sequence" in results.stdout, f"Checkpoint init_step_{i} was not reported"
+                assert f"Reported checkpoint init_step_{i} in sequence" in results.stdout, (
+                    f"Checkpoint init_step_{i} was not reported"
+                )
         else:
             # Verify each checkpoint was reported in order
             for i in range(4):
                 checkpoint_logs = logs_info_level.get_logs(
                     field="message", pattern=f"Reported checkpoint init_step_{i} in sequence"
                 )
-                assert (
-                    len(checkpoint_logs) > 0
-                ), f"Checkpoint init_step_{i} was not reported"
+                assert len(checkpoint_logs) > 0, f"Checkpoint init_step_{i} was not reported"
 
     def test_sequential_supervision_completed(
         self, results: ScenarioResult, logs_info_level: LogContainer, version: str
@@ -94,7 +94,9 @@ def test_sequential_supervision_completed(
         if version == "cpp":
             # For C++ scenarios, check stdout directly
             assert "Would initialize health monitoring with" in results.stdout, "Health monitoring setup not mentioned"
-            assert "All checkpoints reported in correct sequential order" in results.stdout, "No confirmation of sequential checkpoint reporting"
+            assert "All checkpoints reported in correct sequential order" in results.stdout, (
+                "No confirmation of sequential checkpoint reporting"
+            )
         else:
             # Verify health monitor was initialized
             init_logs = logs_info_level.get_logs(
@@ -105,6 +107,4 @@ def test_sequential_supervision_completed(
             completion_logs = logs_info_level.get_logs(
                 field="message", value="All checkpoints reported in correct sequential order"
             )
-            assert (
-                len(completion_logs) > 0
-            ), "No confirmation of sequential checkpoint reporting"
+            assert len(completion_logs) > 0, "No confirmation of sequential checkpoint reporting"

feature_integration_tests/test_cases/tests/lifecycle/test_parallel_launching.py

@@ -78,9 +78,7 @@ def test_parallel_monitors_started(
                 monitor_logs = logs_info_level.get_logs(
                     field="message", pattern=f"Parallel monitor {i} started deadline"
                 )
-                assert (
-                    len(monitor_logs) > 0
-                ), f"Parallel monitor {i} did not start"
+                assert len(monitor_logs) > 0, f"Parallel monitor {i} did not start"
 
     def test_parallel_monitors_completed(
         self, results: ScenarioResult, logs_info_level: LogContainer, version: str
@@ -94,16 +92,14 @@ def test_parallel_monitors_completed(
             # For C++ scenarios, check stdout directly
             for i in range(4):
                 assert f"Parallel monitor {i} completed" in results.stdout, f"Parallel monitor {i} did not complete"
-            assert "parallel monitors completed successfully" in results.stdout, "Not all parallel monitors completed successfully"
+            assert "parallel monitors completed successfully" in results.stdout, (
+                "Not all parallel monitors completed successfully"
+            )
         else:
             # Verify that all monitors completed
             for i in range(4):
-                completion_logs = logs_info_level.get_logs(
-                    field="message", pattern=f"Parallel monitor {i} completed"
-                )
-                assert (
-                    len(completion_logs) > 0
-                ), f"Parallel monitor {i} did not complete"
+                completion_logs = logs_info_level.get_logs(field="message", pattern=f"Parallel monitor {i} completed")
+                assert len(completion_logs) > 0, f"Parallel monitor {i} did not complete"
 
             # Verify final confirmation
             final_logs = logs_info_level.get_logs(

feature_integration_tests/test_cases/tests/lifecycle/test_process_launching.py

@@ -73,12 +73,8 @@ def test_execution_state_reported(
         if version == "cpp":
             assert "Lifecycle client API called" in results.stdout, "Lifecycle client API was not called"
         else:
-            api_logs = logs_info_level.get_logs(
-                field="message", pattern="Lifecycle client API called"
-            )
-            assert (
-                len(api_logs) > 0
-            ), "Lifecycle client API was not called"
+            api_logs = logs_info_level.get_logs(field="message", pattern="Lifecycle client API called")
+            assert len(api_logs) > 0, "Lifecycle client API was not called"
 
     def test_lifecycle_client_integration(
         self, results: ScenarioResult, logs_info_level: LogContainer, version: str
@@ -89,15 +85,15 @@ def test_lifecycle_client_integration(
         assert results.return_code == ResultCode.SUCCESS
 
         if version == "cpp":
-            assert "Testing lifecycle client API integration" in results.stdout, "Lifecycle client integration test not started"
+            assert "Testing lifecycle client API integration" in results.stdout, (
+                "Lifecycle client integration test not started"
+            )
             assert "Application completed successfully" in results.stdout, "Application did not complete successfully"
         else:
             integration_logs = logs_info_level.get_logs(
                 field="message", value="Testing lifecycle client API integration"
             )
             assert len(integration_logs) > 0, "Lifecycle client integration test not started"
 
-            completion_logs = logs_info_level.get_logs(
-                field="message", value="Application completed successfully"
-            )
+            completion_logs = logs_info_level.get_logs(field="message", value="Application completed successfully")
             assert len(completion_logs) > 0, "Application did not complete successfully"

feature_integration_tests/test_scenarios/rust/src/scenarios/lifecycle/launch_manager_support.rs

@@ -50,8 +50,7 @@ impl Scenario for ProcessLaunchingSupport {
     }
 
     fn run(&self, input: &str) -> Result<(), String> {
-        let test_input =
-            LifecycleTestInput::from_json(input).map_err(|e| format!("Parse error: {}", e))?;
+        let test_input = LifecycleTestInput::from_json(input).map_err(|e| format!("Parse error: {}", e))?;
 
         info!("Testing lifecycle client API integration");
 
@@ -88,8 +87,7 @@ impl Scenario for DependencyOrdering {
     }
 
     fn run(&self, input: &str) -> Result<(), String> {
-        let test_input =
-            LifecycleTestInput::from_json(input).map_err(|e| format!("Parse error: {}", e))?;
+        let test_input = LifecycleTestInput::from_json(input).map_err(|e| format!("Parse error: {}", e))?;
 
         info!("Testing sequential deadline reporting for ordered supervision");
 
@@ -103,23 +101,21 @@ impl Scenario for DependencyOrdering {
             let mut deadline_builder = deadline::DeadlineMonitorBuilder::new();
             deadline_builder = deadline_builder.add_deadline(
                 DeadlineTag::from(format!("init_step_{}", i)),
-                TimeRange::new(
-                    Duration::from_millis(50),
-                    Duration::from_millis(300),
-                ),
-            );
-            hm_builder = hm_builder.add_deadline_monitor(
-                MonitorTag::from(format!("step_monitor_{}", i)),
-                deadline_builder,
+                TimeRange::new(Duration::from_millis(50), Duration::from_millis(300)),
             );
+            hm_builder =
+                hm_builder.add_deadline_monitor(MonitorTag::from(format!("step_monitor_{}", i)), deadline_builder);
         }
 
         let _hm = hm_builder
             .build()
             .map_err(|e| format!("Failed to build health monitor: {:?}", e))?;
 
         // Start monitoring (note: in test env without supervisor daemon, this is demonstration only)
-        info!("Health monitor initialized with {} sequential deadline monitors", test_input.checkpoint_count);
+        info!(
+            "Health monitor initialized with {} sequential deadline monitors",
+            test_input.checkpoint_count
+        );
 
         // Demonstrate sequential API usage
         for i in 0..test_input.checkpoint_count {
@@ -147,8 +143,7 @@ impl Scenario for ParallelLaunching {
     }
 
     fn run(&self, input: &str) -> Result<(), String> {
-        let test_input =
-            LifecycleTestInput::from_json(input).map_err(|e| format!("Parse error: {}", e))?;
+        let test_input = LifecycleTestInput::from_json(input).map_err(|e| format!("Parse error: {}", e))?;
 
         info!("Testing parallel health monitoring with multiple monitors");
 
@@ -162,15 +157,9 @@ impl Scenario for ParallelLaunching {
             let mut deadline_builder = deadline::DeadlineMonitorBuilder::new();
             deadline_builder = deadline_builder.add_deadline(
                 DeadlineTag::from(format!("parallel_task_{}", i)),
-                TimeRange::new(
-                    Duration::from_millis(50),
-                    Duration::from_millis(200),
-                ),
-            );
-            hm_builder = hm_builder.add_deadline_monitor(
-                MonitorTag::from(format!("monitor_{}", i)),
-                deadline_builder,
+                TimeRange::new(Duration::from_millis(50), Duration::from_millis(200)),
             );
+            hm_builder = hm_builder.add_deadline_monitor(MonitorTag::from(format!("monitor_{}", i)), deadline_builder);
         }
 
         let _hm = hm_builder
@@ -198,7 +187,10 @@ impl Scenario for ParallelLaunching {
             handle.join().map_err(|_| "Thread join failed")?;
         }
 
-        info!("All {} parallel monitors completed successfully", test_input.checkpoint_count);
+        info!(
+            "All {} parallel monitors completed successfully",
+            test_input.checkpoint_count
+        );
 
         Ok(())
     }