Merge branch 'main' into josh/cas-confirm-tool-call

Resolved conflicts in pyproject.toml and uv.lock — bumped version to 2.10.56.

Author: JoshParkSJ

.github/workflows/test-packages.yml

@@ -130,6 +130,55 @@ jobs:
         working-directory: packages/uipath-platform
         run: uv run pytest
 
+  e2e-uipath-platform:
+    name: E2E (uipath-platform, memory)
+    needs: detect-changed-packages
+    runs-on: ubuntu-latest
+    steps:
+      - name: Check if package changed
+        id: check
+        shell: bash
+        run: |
+          if echo '${{ needs.detect-changed-packages.outputs.packages }}' | jq -e 'index("uipath-platform")' > /dev/null; then
+            echo "skip=false" >> $GITHUB_OUTPUT
+          else
+            echo "skip=true" >> $GITHUB_OUTPUT
+          fi
+
+      - name: Skip
+        if: steps.check.outputs.skip == 'true'
+        shell: bash
+        run: echo "Skipping - no changes to uipath-platform"
+
+      - name: Checkout
+        if: steps.check.outputs.skip != 'true'
+        uses: actions/checkout@v4
+
+      - name: Setup uv
+        if: steps.check.outputs.skip != 'true'
+        uses: astral-sh/setup-uv@v5
+
+      - name: Setup Python
+        if: steps.check.outputs.skip != 'true'
+        uses: actions/setup-python@v5
+        with:
+          python-version: "3.11"
+
+      - name: Install dependencies
+        if: steps.check.outputs.skip != 'true'
+        working-directory: packages/uipath-platform
+        run: uv sync --all-extras --python 3.11
+
+      - name: Run E2E memory tests
+        if: steps.check.outputs.skip != 'true'
+        working-directory: packages/uipath-platform
+        env:
+          UIPATH_URL: ${{ secrets.ALPHA_BASE_URL }}
+          UIPATH_CLIENT_ID: ${{ secrets.ALPHA_TEST_CLIENT_ID }}
+          UIPATH_CLIENT_SECRET: ${{ secrets.ALPHA_TEST_CLIENT_SECRET }}
+          UIPATH_FOLDER_KEY: ${{ secrets.UIPATH_MEMORY_FOLDER }}
+        run: uv run pytest tests/services/test_memory_service_e2e.py -m e2e -v --no-cov
+
   test-uipath:
     name: Test (uipath, ${{ matrix.python-version }}, ${{ matrix.os }})
     needs: detect-changed-packages
@@ -184,7 +233,7 @@ jobs:
 
   test-gate:
     name: Test
-    needs: [test-uipath-core, test-uipath-platform, test-uipath]
+    needs: [test-uipath-core, test-uipath-platform, test-uipath, e2e-uipath-platform]
     runs-on: ubuntu-latest
     if: always()
     steps:
@@ -196,4 +245,8 @@ jobs:
             echo "Tests failed"
             exit 1
           fi
+          # E2E tests are informational — log but don't block
+          if [[ "${{ needs.e2e-uipath-platform.result }}" == "failure" ]]; then
+            echo "⚠️ E2E memory tests failed (non-blocking)"
+          fi
           echo "All tests passed"

packages/uipath-core/src/uipath/core/chat/__init__.py

@@ -103,6 +103,11 @@
     UiPathConversationToolCallResult,
     UiPathConversationToolCallStartEvent,
 )
+from .voice import (
+    UiPathVoiceToolCallMessage,
+    UiPathVoiceToolCallRequest,
+    UiPathVoiceToolCallResult,
+)
 
 __all__ = [
     # Root
@@ -168,4 +173,8 @@
     "UiPathConversationAsyncInputStreamEvent",
     # Meta
     "UiPathConversationMetaEvent",
+    # Voice
+    "UiPathVoiceToolCallRequest",
+    "UiPathVoiceToolCallMessage",
+    "UiPathVoiceToolCallResult",
 ]

packages/uipath-core/src/uipath/core/chat/voice.py

@@ -0,0 +1,30 @@
+"""Voice tool-call wire models (CAS socket.io)."""
+
+from typing import Any
+
+from pydantic import BaseModel, ConfigDict, Field
+
+
+class _VoiceWire(BaseModel):
+    model_config = ConfigDict(validate_by_name=True, validate_by_alias=True)
+
+
+class UiPathVoiceToolCallRequest(_VoiceWire):
+    """Single tool call in a batch."""
+
+    call_id: str = Field(..., alias="callId")
+    tool_name: str = Field(..., alias="toolName")
+    args: dict[str, Any]
+
+
+class UiPathVoiceToolCallMessage(_VoiceWire):
+    """Batch of tool calls from CAS."""
+
+    calls: list[UiPathVoiceToolCallRequest] = Field(..., min_length=1)
+
+
+class UiPathVoiceToolCallResult(_VoiceWire):
+    """Result of a single tool call."""
+
+    result: str
+    is_error: bool = Field(..., alias="isError")

packages/uipath-platform/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "uipath-platform"
-version = "0.1.28"
+version = "0.1.37"
 description = "HTTP client library for programmatic access to UiPath Platform"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"
@@ -98,9 +98,12 @@ warn_required_dynamic_aliases = true
 [tool.pytest.ini_options]
 testpaths = ["tests"]
 python_files = "test_*.py"
-addopts = "-ra -q --cov=src/uipath --cov-report=term-missing"
+addopts = "-ra -q --cov=src/uipath --cov-report=term-missing -m 'not e2e'"
 asyncio_default_fixture_loop_scope = "function"
 asyncio_mode = "auto"
+markers = [
+    "e2e: end-to-end tests against real ECS/LLMOps (requires UIPATH_URL, UIPATH_ACCESS_TOKEN, UIPATH_FOLDER_KEY)",
+]
 
 [tool.coverage.report]
 show_missing = true

packages/uipath-platform/src/uipath/platform/_uipath.py

@@ -8,6 +8,7 @@
 from .action_center import TasksService
 from .agenthub._agenthub_service import AgentHubService
 from .agenthub._remote_a2a_service import RemoteA2aService
+from .automation_ops import AutomationOpsService
 from .chat import ConversationsService, UiPathLlmChatService, UiPathOpenAIService
 from .common import (
     ApiClient,
@@ -22,6 +23,7 @@
 from .entities import EntitiesService
 from .errors import BaseUrlMissingError, SecretMissingError
 from .guardrails import GuardrailsService
+from .memory import MemoryService
 from .orchestrator import (
     AssetsService,
     AttachmentsService,
@@ -34,6 +36,7 @@
     QueuesService,
 )
 from .resource_catalog import ResourceCatalogService
+from .semantic_proxy import SemanticProxyService
 
 
 def _has_valid_client_credentials(
@@ -113,6 +116,10 @@ def context_grounding(self) -> ContextGroundingService:
             self.buckets,
         )
 
+    @property
+    def memory(self) -> MemoryService:
+        return MemoryService(self._config, self._execution_context, self.folders)
+
     @property
     def documents(self) -> DocumentsService:
         return DocumentsService(self._config, self._execution_context)
@@ -173,6 +180,14 @@ def remote_a2a(self) -> RemoteA2aService:
     def orchestrator_setup(self) -> OrchestratorSetupService:
         return OrchestratorSetupService(self._config, self._execution_context)
 
+    @property
+    def automation_ops(self) -> AutomationOpsService:
+        return AutomationOpsService(self._config, self._execution_context)
+
+    @property
+    def semantic_proxy(self) -> SemanticProxyService:
+        return SemanticProxyService(self._config, self._execution_context)
+
     @property
     def automation_tracker(self) -> AutomationTrackerService:
         return AutomationTrackerService(self._config, self._execution_context)

packages/uipath-platform/src/uipath/platform/automation_ops/__init__.py

@@ -0,0 +1,9 @@
+"""AutomationOps service package.
+
+Provides the ``AutomationOpsService`` client for retrieving deployed AI Trust
+Layer policies from AgentHub.
+"""
+
+from ._automation_ops_service import AutomationOpsService
+
+__all__ = ["AutomationOpsService"]

packages/uipath-platform/src/uipath/platform/automation_ops/_automation_ops_service.py

@@ -0,0 +1,64 @@
+"""AutomationOps service for UiPath Platform.
+
+Provides methods for retrieving deployed policies from the AgentHub service.
+"""
+
+from typing import Any
+
+from uipath.core.tracing import traced
+
+from ..common._base_service import BaseService
+from ..common._config import UiPathApiConfig
+from ..common._execution_context import UiPathExecutionContext
+from ..common._models import Endpoint, RequestSpec
+
+_DEPLOYED_POLICY_ENDPOINT = Endpoint("agenthub_/api/policies/deployed-policy")
+
+
+class AutomationOpsService(BaseService):
+    """Service for interacting with UiPath AutomationOps policies via AgentHub."""
+
+    def __init__(
+        self,
+        config: UiPathApiConfig,
+        execution_context: UiPathExecutionContext,
+    ) -> None:
+        super().__init__(config=config, execution_context=execution_context)
+
+    @traced(name="automation_ops_get_deployed_policy", run_type="uipath")
+    def get_deployed_policy(self) -> dict[str, Any]:
+        """Retrieve the deployed policy.
+
+        Returns:
+            The deployed policy response as a dictionary.
+        """
+        spec = self._deployed_policy_spec()
+        response = self.request(
+            spec.method,
+            url=spec.endpoint,
+            headers=spec.headers,
+            scoped="tenant",
+        )
+        return response.json()
+
+    @traced(name="automation_ops_get_deployed_policy", run_type="uipath")
+    async def get_deployed_policy_async(self) -> dict[str, Any]:
+        """Retrieve the deployed policy (async).
+
+        Returns:
+            The deployed policy response as a dictionary.
+        """
+        spec = self._deployed_policy_spec()
+        response = await self.request_async(
+            spec.method,
+            url=spec.endpoint,
+            headers=spec.headers,
+            scoped="tenant",
+        )
+        return response.json()
+
+    def _deployed_policy_spec(self) -> RequestSpec:
+        return RequestSpec(
+            method="POST",
+            endpoint=_DEPLOYED_POLICY_ENDPOINT,
+        )

packages/uipath-platform/src/uipath/platform/common/_bindings.py

@@ -52,7 +52,15 @@ def folder_identifier(self) -> str:
 
 class GenericResourceOverwrite(ResourceOverwrite):
     resource_type: Literal[
-        "process", "index", "app", "asset", "bucket", "mcpServer", "queue"
+        "process",
+        "index",
+        "app",
+        "asset",
+        "bucket",
+        "mcpServer",
+        "queue",
+        "remoteA2aAgent",
+        "memorySpace",
     ]
     name: str = Field(alias="name")
     folder_path: str = Field(alias="folderPath")