Fixed logging bug, added chat template (#125)

* fixed logging model input, added template

Signed-off-by: Mandana Vaziri <[email protected]>

* cleanup

Signed-off-by: Mandana Vaziri <[email protected]>

---------

Signed-off-by: Mandana Vaziri <[email protected]>

Author: vazirim

src/pdl/pdl_interpreter.py

@@ -1051,7 +1051,9 @@ def get_transformed_inputs(kwargs):
         if "input" in litellm_params:
             append_log(state, "Model Input", litellm_params["input"])
         else:
-            append_log(state, "Model Input", model_input)
+            append_log(
+                state, "Model Input", messages_to_str(concrete_block.model, model_input)
+            )
         background: Messages = [msg]
         result = msg["content"]
         append_log(state, "Model Output", result)
@@ -1093,7 +1095,7 @@ def generate_client_response_streaming(
     model_input: Messages,
 ) -> Generator[YieldMessage, Any, Message]:
     msg_stream: Generator[Message, Any, None]
-    model_input_str = messages_to_str(model_input)
+    model_input_str = messages_to_str(block.model, model_input)
     match block:
         case BamModelBlock():
             msg_stream = BamModel.generate_text_stream(
@@ -1148,7 +1150,7 @@ def generate_client_response_single(
     model_input: Messages,
 ) -> Generator[YieldMessage, Any, Message]:
     msg: Message
-    model_input_str = messages_to_str(model_input)
+    model_input_str = messages_to_str(block.model, model_input)
     match block:
         case BamModelBlock():
             msg = BamModel.generate_text(
@@ -1178,7 +1180,7 @@ def generate_client_response_batching(  # pylint: disable=too-many-arguments
     # model: str,
     model_input: Messages,
 ) -> Generator[YieldMessage, Any, Message]:
-    model_input_str = messages_to_str(model_input)
+    model_input_str = messages_to_str(block.model, model_input)
     match block:
         case BamModelBlock():
             msg = yield ModelCallMessage(

src/pdl/pdl_utils.py

@@ -32,15 +32,20 @@ def messages_concat(messages1: Messages, messages2: Messages) -> Messages:
     return messages1 + messages2
 
 
-def messages_to_str(messages: Messages) -> str:
-    # TODO
-    return "".join(
-        [
-            (
-                msg["content"]
-                if msg["role"] is None
-                else f"<|{msg['role']}|>{msg['content']}"
-            )
-            for msg in messages
-        ]
+def messages_to_str(model_id: str, messages: Messages) -> str:
+    if "granite-3b" not in model_id and "granite-8b" not in model_id:
+        return "".join([(msg["content"]) for msg in messages])
+    return (
+        "".join(
+            [
+                (
+                    msg["content"]
+                    if msg["role"] is None
+                    # else f"<|{msg['role']}|>{msg['content']}"
+                    else f"<|start_of_role|>{msg['role']}<|end_of_role|>{msg['content']}<|end_of_text|>\n"
+                )
+                for msg in messages
+            ]
+        )
+        + "<|start_of_role|>assistant<|end_of_role|>"
     )