Merge pull request #95 from UiPath/feat/uipath-platform

chore: import triggers from core

Author: radu-mocanu

pyproject.toml

@@ -1,11 +1,11 @@
 [project]
 name = "uipath-runtime"
-version = "0.9.0"
+version = "0.9.1"
 description = "Runtime abstractions and interfaces for building agents and automation scripts in the UiPath ecosystem"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"
 dependencies = [
-  "uipath-core>=0.5.0, <0.6.0",
+  "uipath-core>=0.5.2, <0.6.0"
 ]
 classifiers = [
   "Intended Audience :: Developers",

src/uipath/runtime/__init__.py

@@ -1,5 +1,12 @@
 """UiPath Runtime Package."""
 
+from uipath.core.triggers import (
+    UiPathApiTrigger,
+    UiPathResumeTrigger,
+    UiPathResumeTriggerName,
+    UiPathResumeTriggerType,
+)
+
 from uipath.runtime.base import (
     UiPathExecuteOptions,
     UiPathExecutionRuntime,
@@ -33,12 +40,6 @@
 from uipath.runtime.resumable.runtime import (
     UiPathResumableRuntime,
 )
-from uipath.runtime.resumable.trigger import (
-    UiPathApiTrigger,
-    UiPathResumeTrigger,
-    UiPathResumeTriggerName,
-    UiPathResumeTriggerType,
-)
 from uipath.runtime.schema import UiPathRuntimeSchema
 from uipath.runtime.storage import UiPathRuntimeStorageProtocol
 

src/uipath/runtime/chat/protocol.py

@@ -5,8 +5,7 @@
 from uipath.core.chat import (
     UiPathConversationMessageEvent,
 )
-
-from uipath.runtime.resumable.trigger import UiPathResumeTrigger
+from uipath.core.triggers import UiPathResumeTrigger
 
 
 class UiPathChatProtocol(Protocol):

src/uipath/runtime/chat/runtime.py

@@ -3,6 +3,8 @@
 import logging
 from typing import Any, AsyncGenerator, cast
 
+from uipath.core.triggers import UiPathResumeTriggerType
+
 from uipath.runtime.base import (
     UiPathExecuteOptions,
     UiPathRuntimeProtocol,
@@ -17,7 +19,6 @@
     UiPathRuntimeResult,
     UiPathRuntimeStatus,
 )
-from uipath.runtime.resumable.trigger import UiPathResumeTriggerType
 from uipath.runtime.schema import UiPathRuntimeSchema
 
 logger = logging.getLogger(__name__)

src/uipath/runtime/debug/runtime.py

@@ -5,6 +5,10 @@
 from typing import Any, AsyncGenerator, cast
 
 from uipath.core.errors import UiPathPendingTriggerError
+from uipath.core.triggers import (
+    UiPathResumeTrigger,
+    UiPathResumeTriggerType,
+)
 
 from uipath.runtime.base import (
     UiPathExecuteOptions,
@@ -27,10 +31,6 @@
 )
 from uipath.runtime.resumable.protocols import UiPathResumeTriggerReaderProtocol
 from uipath.runtime.resumable.runtime import UiPathResumableRuntime
-from uipath.runtime.resumable.trigger import (
-    UiPathResumeTrigger,
-    UiPathResumeTriggerType,
-)
 from uipath.runtime.schema import UiPathRuntimeSchema
 
 logger = logging.getLogger(__name__)

src/uipath/runtime/result.py

@@ -4,10 +4,10 @@
 from typing import Any
 
 from pydantic import BaseModel, Field
+from uipath.core.triggers import UiPathResumeTrigger
 
 from uipath.runtime.errors import UiPathErrorContract
 from uipath.runtime.events import UiPathRuntimeEvent, UiPathRuntimeEventType
-from uipath.runtime.resumable.trigger import UiPathResumeTrigger
 
 
 class UiPathRuntimeStatus(str, Enum):

src/uipath/runtime/resumable/__init__.py

@@ -1,23 +1,24 @@
 """Module for resumable runtime features."""
 
+from uipath.core.triggers import (
+    UiPathApiTrigger,
+    UiPathResumeTrigger,
+    UiPathResumeTriggerType,
+)
+
 from uipath.runtime.resumable.protocols import (
     UiPathResumableStorageProtocol,
     UiPathResumeTriggerCreatorProtocol,
     UiPathResumeTriggerProtocol,
     UiPathResumeTriggerReaderProtocol,
 )
-from uipath.runtime.resumable.trigger import (
-    UiPathApiTrigger,
-    UiPathResumeTrigger,
-    UiPathResumeTriggerType,
-)
 
 __all__ = [
     "UiPathResumableStorageProtocol",
     "UiPathResumeTriggerCreatorProtocol",
     "UiPathResumeTriggerReaderProtocol",
     "UiPathResumeTriggerProtocol",
+    "UiPathApiTrigger",
     "UiPathResumeTrigger",
     "UiPathResumeTriggerType",
-    "UiPathApiTrigger",
 ]

src/uipath/runtime/resumable/protocols.py

@@ -2,7 +2,8 @@
 
 from typing import Any, Protocol
 
-from uipath.runtime.resumable.trigger import UiPathResumeTrigger
+from uipath.core.triggers import UiPathResumeTrigger
+
 from uipath.runtime.storage import UiPathRuntimeStorageProtocol
 
 

src/uipath/runtime/resumable/runtime.py

@@ -4,6 +4,7 @@
 from typing import Any, AsyncGenerator
 
 from uipath.core.errors import UiPathPendingTriggerError
+from uipath.core.triggers import UiPathResumeTrigger, UiPathResumeTriggerType
 
 from uipath.runtime.base import (
     UiPathExecuteOptions,
@@ -16,12 +17,10 @@
     UiPathRuntimeResult,
     UiPathRuntimeStatus,
 )
-from uipath.runtime.resumable import UiPathResumeTriggerType
 from uipath.runtime.resumable.protocols import (
     UiPathResumableStorageProtocol,
     UiPathResumeTriggerProtocol,
 )
-from uipath.runtime.resumable.trigger import UiPathResumeTrigger
 from uipath.runtime.schema import UiPathRuntimeSchema
 
 logger = logging.getLogger(__name__)

src/uipath/runtime/resumable/trigger.py

@@ -1,69 +1,15 @@
-"""Module defining resume trigger types and data models."""
-
-from enum import Enum
-from typing import Any
-
-from pydantic import BaseModel, ConfigDict, Field
-
-
-class UiPathResumeTriggerType(str, Enum):
-    """Constants representing different types of resume job triggers in the system."""
-
-    NONE = "None"
-    QUEUE_ITEM = "QueueItem"
-    JOB = "Job"
-    TASK = "Task"
-    TIMER = "Timer"
-    INBOX = "Inbox"
-    API = "Api"
-    DEEP_RAG = "DeepRag"
-    BATCH_RAG = "BatchRag"
-    INDEX_INGESTION = "IndexIngestion"
-    IXP_EXTRACTION = "IxpExtraction"
-    IXP_VS_ESCALATION = "IxpVsEscalation"
-
-
-class UiPathResumeTriggerName(str, Enum):
-    """Constants representing specific names for resume job triggers in the system."""
-
-    UNKNOWN = "Unknown"
-    QUEUE_ITEM = "QueueItem"
-    JOB = "Job"
-    TASK = "Task"
-    ESCALATION = "Escalation"
-    TIMER = "Timer"
-    INBOX = "Inbox"
-    API = "Api"
-    DEEP_RAG = "DeepRag"
-    BATCH_RAG = "BatchRag"
-    INDEX_INGESTION = "IndexIngestion"
-    EXTRACTION = "Extraction"
-    IXP_VS_ESCALATION = "IxpVsEscalation"
-
-
-class UiPathApiTrigger(BaseModel):
-    """API resume trigger request."""
-
-    inbox_id: str | None = Field(default=None, alias="inboxId")
-    request: Any = None
-
-    model_config = ConfigDict(validate_by_name=True)
-
-
-class UiPathResumeTrigger(BaseModel):
-    """Information needed to resume execution."""
-
-    interrupt_id: str | None = Field(default=None, alias="interruptId")
-    trigger_type: UiPathResumeTriggerType = Field(
-        default=UiPathResumeTriggerType.API, alias="triggerType"
-    )
-    trigger_name: UiPathResumeTriggerName = Field(
-        default=UiPathResumeTriggerName.UNKNOWN, alias="triggerName", exclude=True
-    )
-    item_key: str | None = Field(default=None, alias="itemKey")
-    api_resume: UiPathApiTrigger | None = Field(default=None, alias="apiResume")
-    folder_path: str | None = Field(default=None, alias="folderPath")
-    folder_key: str | None = Field(default=None, alias="folderKey")
-    payload: Any | None = Field(default=None, alias="interruptObject", exclude=True)
-
-    model_config = ConfigDict(validate_by_name=True)
+"""Re-export trigger types from uipath.core.triggers for backward compatibility."""
+
+from uipath.core.triggers import (
+    UiPathApiTrigger,
+    UiPathResumeTrigger,
+    UiPathResumeTriggerName,
+    UiPathResumeTriggerType,
+)
+
+__all__ = [
+    "UiPathApiTrigger",
+    "UiPathResumeTrigger",
+    "UiPathResumeTriggerName",
+    "UiPathResumeTriggerType",
+]