feat: Interrupt for low coded CAS agents [JAR-9208] (#641)

Author: JoshParkSJ

…gent/tools/durable_interrupt/__init__.py …ain/_utils/durable_interrupt/__init__.pysrc/uipath_langchain/agent/tools/durable_interrupt/__init__.py renamed to src/uipath_langchain/_utils/durable_interrupt/__init__.py src/uipath_langchain/agent/tools/durable_interrupt/__init__.py renamed to src/uipath_langchain/_utils/durable_interrupt/__init__.py

@@ -1,6 +1,9 @@
 """Durable interrupt package for side-effect-safe interrupt/resume in LangGraph."""
 
-from .decorator import _durable_state, durable_interrupt
+from .decorator import (
+    _durable_state,
+    durable_interrupt,
+)
 from .skip_interrupt import SkipInterruptValue
 
 __all__ = [

…ent/tools/durable_interrupt/decorator.py …in/_utils/durable_interrupt/decorator.pysrc/uipath_langchain/agent/tools/durable_interrupt/decorator.py renamed to src/uipath_langchain/_utils/durable_interrupt/decorator.py src/uipath_langchain/agent/tools/durable_interrupt/decorator.py renamed to src/uipath_langchain/_utils/durable_interrupt/decorator.py

@@ -26,6 +26,7 @@
 from uipath.runtime.errors import UiPathErrorCategory
 
 from uipath_langchain._utils import get_execution_folder_path
+from uipath_langchain._utils.durable_interrupt import durable_interrupt
 from uipath_langchain.agent.exceptions import AgentStartupError, AgentStartupErrorCode
 from uipath_langchain.agent.react.jsonschema_pydantic_converter import (
     create_model as create_model_from_schema,
@@ -40,7 +41,6 @@
 )
 from uipath_langchain.retrievers import ContextGroundingRetriever
 
-from .durable_interrupt import durable_interrupt
 from .structured_tool_with_argument_properties import (
     StructuredToolWithArgumentProperties,
 )

…ools/durable_interrupt/skip_interrupt.py …tils/durable_interrupt/skip_interrupt.pysrc/uipath_langchain/agent/tools/durable_interrupt/skip_interrupt.py renamed to src/uipath_langchain/_utils/durable_interrupt/skip_interrupt.py src/uipath_langchain/agent/tools/durable_interrupt/skip_interrupt.py renamed to src/uipath_langchain/_utils/durable_interrupt/skip_interrupt.py

@@ -21,6 +21,7 @@
 from uipath.runtime.errors import UiPathErrorCategory
 
 from uipath_langchain._utils import get_execution_folder_path
+from uipath_langchain._utils.durable_interrupt import durable_interrupt
 from uipath_langchain.agent.react.jsonschema_pydantic_converter import create_model
 from uipath_langchain.agent.tools.static_args import (
     handle_static_args,
@@ -31,7 +32,6 @@
 
 from ..exceptions import AgentRuntimeError, AgentRuntimeErrorCode
 from ..react.types import AgentGraphState
-from .durable_interrupt import durable_interrupt
 from .tool_node import ToolWrapperReturnType
 from .utils import (
     resolve_task_title,

src/uipath_langchain/agent/tools/context_tool.py

@@ -26,13 +26,13 @@
 )
 from uipath.runtime.errors import UiPathErrorCategory
 
-from uipath_langchain.agent.exceptions import AgentStartupError, AgentStartupErrorCode
-from uipath_langchain.agent.react.jsonschema_pydantic_converter import create_model
-from uipath_langchain.agent.react.types import AgentGraphState
-from uipath_langchain.agent.tools.durable_interrupt import (
+from uipath_langchain._utils.durable_interrupt import (
     SkipInterruptValue,
     durable_interrupt,
 )
+from uipath_langchain.agent.exceptions import AgentStartupError, AgentStartupErrorCode
+from uipath_langchain.agent.react.jsonschema_pydantic_converter import create_model
+from uipath_langchain.agent.react.types import AgentGraphState
 from uipath_langchain.agent.tools.internal_tools.schema_utils import (
     BATCH_TRANSFORM_OUTPUT_SCHEMA,
     add_query_field_to_schema,

src/uipath_langchain/agent/tools/escalation_tool.py

@@ -22,13 +22,13 @@
 )
 from uipath.runtime.errors import UiPathErrorCategory
 
-from uipath_langchain.agent.exceptions import AgentStartupError, AgentStartupErrorCode
-from uipath_langchain.agent.react.jsonschema_pydantic_converter import create_model
-from uipath_langchain.agent.react.types import AgentGraphState
-from uipath_langchain.agent.tools.durable_interrupt import (
+from uipath_langchain._utils.durable_interrupt import (
     SkipInterruptValue,
     durable_interrupt,
 )
+from uipath_langchain.agent.exceptions import AgentStartupError, AgentStartupErrorCode
+from uipath_langchain.agent.react.jsonschema_pydantic_converter import create_model
+from uipath_langchain.agent.react.types import AgentGraphState
 from uipath_langchain.agent.tools.internal_tools.schema_utils import (
     add_query_field_to_schema,
 )

src/uipath_langchain/agent/tools/internal_tools/batch_transform_tool.py

@@ -18,14 +18,14 @@
 )
 from uipath.runtime.errors import UiPathErrorCategory
 
+from uipath_langchain._utils.durable_interrupt import durable_interrupt
 from uipath_langchain.agent.react.types import AgentGraphState
 from uipath_langchain.agent.tools.tool_node import (
     ToolWrapperMixin,
     ToolWrapperReturnType,
 )
 
 from ..exceptions import AgentRuntimeError, AgentRuntimeErrorCode
-from .durable_interrupt import durable_interrupt
 from .structured_tool_with_output_type import StructuredToolWithOutputType
 from .utils import (
     resolve_task_title,

src/uipath_langchain/agent/tools/internal_tools/deeprag_tool.py

@@ -13,6 +13,7 @@
 from uipath.platform.orchestrator import JobState
 
 from uipath_langchain._utils import get_execution_folder_path
+from uipath_langchain._utils.durable_interrupt import durable_interrupt
 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
@@ -24,7 +25,6 @@
     ToolWrapperReturnType,
 )
 
-from .durable_interrupt import durable_interrupt
 from .utils import sanitize_tool_name
 
 

src/uipath_langchain/agent/tools/ixp_escalation_tool.py

@@ -16,6 +16,8 @@
     LowCodeAgentDefinition,
 )
 
+from uipath_langchain.chat.hitl import REQUIRE_CONVERSATIONAL_CONFIRMATION
+
 from .context_tool import create_context_tool
 from .escalation_tool import create_escalation_tool
 from .extraction_tool import create_ixp_extraction_tool
@@ -54,6 +56,15 @@ async def create_tools_from_resources(
             else:
                 tools.append(tool)
 
+                if agent.is_conversational:
+                    props = getattr(resource, "properties", None)
+                    if props and getattr(
+                        props, REQUIRE_CONVERSATIONAL_CONFIRMATION, False
+                    ):
+                        if tool.metadata is None:
+                            tool.metadata = {}
+                        tool.metadata[REQUIRE_CONVERSATIONAL_CONFIRMATION] = True
+
     return tools