get branch green

Author: dtam

guardrails/api_client.py

@@ -104,7 +104,7 @@ def stream_validate(
                     )
                 if line:
                     json_output = json.loads(line)
-                    if(json_output.get("error")):
+                    if json_output.get("error"):
                         raise Exception(json_output.get("error").get("message"))
                     yield IValidationOutcome.from_dict(json_output)
 

guardrails/async_guard.py

@@ -574,7 +574,8 @@ async def _stream_server_call(
                         validated_output=validated_output,
                         validation_passed=(validation_output.validation_passed is True),
                     )
-            # TODO re-enable this once we have a way to get history from a multi-node server
+            # TODO re-enable this once we have a way to get history
+            # from a multi-node server
             # if validation_output:
             #     guard_history = self._api_client.get_history(
             #         self.name, validation_output.call_id

guardrails/classes/llm/llm_response.py

@@ -47,7 +47,8 @@ def to_interface(self) -> ILLMResponse:
             stream_output = [str(so) for so in copy_2]
 
         async_stream_output = None
-        # dont do this again if already aiter-able were updating ourselves here so in memory
+        # dont do this again if already aiter-able were updating
+        # ourselves here so in memory
         # this can cause issues
         if self.async_stream_output and not hasattr(
             self.async_stream_output, "__aiter__"

guardrails/guard.py

@@ -1215,7 +1215,8 @@ def _single_server_call(self, *, payload: Dict[str, Any]) -> ValidationOutcome[O
                     error="The response from the server was empty!",
                 )
 
-            # TODO renable this when we have history support in multi-node server environments
+            # TODO renable this when we have history support in
+            # multi-node server environments
             # guard_history = self._api_client.get_history(
             #     self.name, validation_output.call_id
             # )