From 3b352af43638f5ab814c5cb9729cd1719bd8aa80 Mon Sep 17 00:00:00 2001
From: Nathan Duchesne <nduc@bendingspoons.com>
Date: Wed, 29 Oct 2025 19:14:18 +0100
Subject: [PATCH] refactor: made all thread item conversion functions async

---
 chatkit/agents.py | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/chatkit/agents.py b/chatkit/agents.py
index 38543d1..ac0594b 100644
--- a/chatkit/agents.py
+++ b/chatkit/agents.py
@@ -656,7 +656,7 @@ def tag_to_message_content(
             "A Tag was included in a UserMessageItem but Converter.tag_to_message_content is not implemented"
         )
 
-    def hidden_context_to_input(
+    async def hidden_context_to_input(
         self, item: HiddenContextItem
     ) -> TResponseInputItem | list[TResponseInputItem] | None:
         """
@@ -667,7 +667,7 @@ def hidden_context_to_input(
             "HiddenContextItem were present in a user message but Converter.hidden_context_to_input was not implemented"
         )
 
-    def task_to_input(
+    async def task_to_input(
         self, item: TaskItem
     ) -> TResponseInputItem | list[TResponseInputItem] | None:
         """
@@ -692,7 +692,7 @@ def task_to_input(
             role="user",
         )
 
-    def workflow_to_input(
+    async def workflow_to_input(
         self, item: WorkflowItem
     ) -> TResponseInputItem | list[TResponseInputItem] | None:
         """
@@ -722,7 +722,7 @@ def workflow_to_input(
             )
         return messages
 
-    def widget_to_input(
+    async def widget_to_input(
         self, item: WidgetItem
     ) -> TResponseInputItem | list[TResponseInputItem] | None:
         """
@@ -892,16 +892,16 @@ async def _thread_item_to_input_item(
                 out = await self.end_of_turn_to_input(item) or []
                 return out if isinstance(out, list) else [out]
             case WidgetItem():
-                out = self.widget_to_input(item) or []
+                out = await self.widget_to_input(item) or []
                 return out if isinstance(out, list) else [out]
             case WorkflowItem():
-                out = self.workflow_to_input(item) or []
+                out = await self.workflow_to_input(item) or []
                 return out if isinstance(out, list) else [out]
             case TaskItem():
-                out = self.task_to_input(item) or []
+                out = await self.task_to_input(item) or []
                 return out if isinstance(out, list) else [out]
             case HiddenContextItem():
-                out = self.hidden_context_to_input(item) or []
+                out = await self.hidden_context_to_input(item) or []
                 return out if isinstance(out, list) else [out]
             case _:
                 assert_never(item)