chore: Format code for line length and remove unused imports

- Wrap long lines in manifest.py, lb_handler.py, and load_balancer_sls.py
- Remove unused httpx import in test_load_balancer_sls_stub.py
- Apply consistent formatting across codebase

src/tetra_rp/cli/commands/build_utils/manifest.py

@@ -66,7 +66,10 @@ def build(self) -> Dict[str, Any]:
 
             # Validate and collect routing for LB endpoints
             resource_routes = {}
-            is_load_balanced = resource_type in ["LoadBalancerSlsResource", "LiveLoadBalancer"]
+            is_load_balanced = resource_type in [
+                "LoadBalancerSlsResource",
+                "LiveLoadBalancer",
+            ]
             if is_load_balanced:
                 for f in functions:
                     if not f.http_method or not f.http_path:

src/tetra_rp/cli/commands/build_utils/scanner.py

@@ -82,7 +82,9 @@ def _extract_resource_configs(self, tree: ast.AST, py_file: Path) -> None:
                         config_type = self._get_call_type(node.value)
 
                         # Include both Serverless and LoadBalancer resources
-                        if config_type and ("Serverless" in config_type or "LoadBalancer" in config_type):
+                        if config_type and (
+                            "Serverless" in config_type or "LoadBalancer" in config_type
+                        ):
                             # Store mapping of variable name to name and type separately
                             key = f"{module_path}:{config_name}"
                             self.resource_configs[key] = config_name

src/tetra_rp/runtime/lb_handler.py

@@ -160,7 +160,9 @@ async def execute_remote_function(request: Request) -> Dict[str, Any]:
 
                 # Serialize result
                 try:
-                    result_b64 = base64.b64encode(cloudpickle.dumps(result)).decode("utf-8")
+                    result_b64 = base64.b64encode(cloudpickle.dumps(result)).decode(
+                        "utf-8"
+                    )
                     return {"success": True, "result": result_b64}
                 except Exception as e:
                     logger.error(f"Failed to serialize result: {e}")

src/tetra_rp/stubs/load_balancer_sls.py

@@ -81,7 +81,9 @@ def _should_use_execute_endpoint(self, func: Callable[..., Any]) -> bool:
 
         # Check if routing metadata is complete
         if not routing_config.get("method") or not routing_config.get("path"):
-            log.debug(f"Incomplete routing config for {func.__name__}, using /execute fallback")
+            log.debug(
+                f"Incomplete routing config for {func.__name__}, using /execute fallback"
+            )
             return True
 
         # Use user-defined route for deployed endpoints with complete routing metadata
@@ -297,7 +299,9 @@ async def _execute_via_user_route(
                 response = await client.request(method, url, json=body)
                 response.raise_for_status()
                 result = response.json()
-                log.debug(f"User route execution successful (type={type(result).__name__})")
+                log.debug(
+                    f"User route execution successful (type={type(result).__name__})"
+                )
                 return result
         except httpx.TimeoutException as e:
             raise TimeoutError(

tests/integration/test_lb_remote_execution.py

@@ -261,7 +261,7 @@ def test_scanner_discovers_load_balancer_resources(self):
         import tempfile
 
         # Create temporary Python file with LoadBalancer resource
-        code = '''
+        code = """
 from tetra_rp import LiveLoadBalancer, LoadBalancerSlsResource, remote
 
 # Test LiveLoadBalancer discovery
@@ -277,7 +277,7 @@ async def process_data(x: int):
 @remote(deployed, method="GET", path="/api/status")
 def get_status():
     return {"status": "ok"}
-'''
+"""
 
         with tempfile.TemporaryDirectory() as tmpdir:
             project_dir = Path(tmpdir)

tests/unit/test_load_balancer_sls_stub.py

@@ -328,8 +328,6 @@ async def test_execute_via_user_route_success(self):
         def add(x, y):
             return x + y
 
-        import httpx
-
         mock_response = MagicMock()
         mock_response.json.return_value = {"result": 8}
 
@@ -343,7 +341,9 @@ def add(x, y):
             assert result == {"result": 8}
             # Verify correct HTTP method and URL
             mock_client.return_value.__aenter__.return_value.request.assert_called_once()
-            call_args = mock_client.return_value.__aenter__.return_value.request.call_args
+            call_args = (
+                mock_client.return_value.__aenter__.return_value.request.call_args
+            )
             assert call_args[0][0] == "POST"
             assert call_args[0][1] == "http://localhost:8000/api/add"
             # Verify correct JSON body with mapped parameters
@@ -374,7 +374,9 @@ def greet(name, greeting="Hello"):
 
             assert result == "Hi, Alice!"
             # Verify JSON body has both positional arg and kwargs
-            call_args = mock_client.return_value.__aenter__.return_value.request.call_args
+            call_args = (
+                mock_client.return_value.__aenter__.return_value.request.call_args
+            )
             assert call_args[1]["json"] == {"name": "Alice", "greeting": "Hi"}
 
     @pytest.mark.asyncio