feat: add attachment extraction on process tool

pyproject.toml

@@ -1,11 +1,11 @@
 [project]
 name = "uipath-langchain"
-version = "0.5.10"
+version = "0.5.11"
 description = "Python SDK that enables developers to build and deploy LangGraph agents to the UiPath Cloud Platform"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"
 dependencies = [
-    "uipath>=2.6.11,<2.7.0",
+    "uipath>=2.6.22,<2.7.0",
     "uipath-runtime>=0.6.0, <0.7.0",
     "langgraph>=1.0.0, <2.0.0",
     "langchain-core>=1.2.5, <2.0.0",

src/uipath_langchain/agent/tools/process_tool.py

@@ -10,6 +10,7 @@
 from uipath.eval.mocks import mockable
 from uipath.platform.common import InvokeProcess
 
+from uipath_langchain.agent.react.job_attachments import get_job_attachments
 from uipath_langchain.agent.react.jsonschema_pydantic_converter import create_model
 from uipath_langchain.agent.react.types import AgentGraphState
 from uipath_langchain.agent.tools.static_args import handle_static_args
@@ -43,12 +44,14 @@ def create_process_tool(resource: AgentProcessToolResourceConfig) -> StructuredT
         example_calls=resource.properties.example_calls,
     )
     async def process_tool_fn(**kwargs: Any):
+        attachments = get_job_attachments(input_model, kwargs)
         return interrupt(
             InvokeProcess(
                 name=process_name,
                 input_arguments=kwargs,
                 process_folder_path=folder_path,
                 process_folder_key=None,
+                attachments=attachments,
             )
         )
 

src/uipath_langchain/runtime/storage.py

@@ -5,6 +5,7 @@
 
 from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver
 from pydantic import BaseModel
+from uipath.core.serialization import serialize_json
 from uipath.runtime import UiPathResumeTrigger
 
 
@@ -82,7 +83,6 @@ async def save_triggers(
                 (runtime_id,),
             )
 
-            # Insert new triggers
             for trigger in triggers:
                 trigger_data = trigger.model_dump()
                 trigger_data["payload"] = trigger.payload
@@ -97,7 +97,7 @@ async def save_triggers(
                     (
                         runtime_id,
                         trigger.interrupt_id,
-                        json.dumps(trigger_data),
+                        serialize_json(trigger_data),
                     ),
                 )
             await self.memory.conn.commit()
@@ -206,11 +206,9 @@ async def get_value(self, runtime_id: str, namespace: str, key: str) -> Any:
     def _dump_value(self, value: str | dict[str, Any] | BaseModel | None) -> str | None:
         if value is None:
             return None
-        if isinstance(value, BaseModel):
-            return "j:" + json.dumps(value.model_dump())
-        if isinstance(value, dict):
-            return "j:" + json.dumps(value)
-        return "s:" + value
+        if isinstance(value, str):
+            return "s:" + value
+        return "j:" + serialize_json(value)
 
     def _load_value(self, raw: str | None) -> Any:
         if raw is None: