Version 1.4.102

Author: gyanendra8

abacusai/__init__.py

@@ -56,6 +56,7 @@
 from .constants_autocomplete_response import ConstantsAutocompleteResponse
 from .conversation_and_project_search_results import ConversationAndProjectSearchResults
 from .cowork_desktop_folder import CoworkDesktopFolder
+from .cowork_dispatch_attachment import CoworkDispatchAttachment
 from .cowork_dispatch_message import CoworkDispatchMessage
 from .cowork_paired_desktop_folders import CoworkPairedDesktopFolders
 from .cowork_pairing_challenge import CoworkPairingChallenge
@@ -181,6 +182,7 @@
 from .mcp_server_connection import McpServerConnection
 from .mcp_server_query_result import McpServerQueryResult
 from .media_artifact import MediaArtifact
+from .media_project import MediaProject
 from .memory_options import MemoryOptions
 from .messaging_connector_response import MessagingConnectorResponse
 from .mobile_app_build_status import MobileAppBuildStatus
@@ -314,4 +316,4 @@
 from .workflow_node_template import WorkflowNodeTemplate
 
 
-__version__ = "1.4.101"
+__version__ = "1.4.102"

abacusai/api_class/dataset_application_connector.py

@@ -340,6 +340,32 @@ def __post_init__(self):
                 self.object_type = normalized_object_type
 
 
+@dataclasses.dataclass
+class MondayDatasetConfig(ApplicationConnectorDatasetConfig):
+    """
+    Dataset config for Monday.com Application Connector
+
+    Args:
+        object_type (str): The Monday.com object to fetch (e.g. boards, workspaces, users, updates, items).
+        board_id (str): The Monday.com board id to fetch items from. Required only when object_type is 'items'.
+    """
+    object_type: str = dataclasses.field(default=None)
+    board_id: str = dataclasses.field(default=None)
+
+    def __post_init__(self):
+        self.application_connector_type = enums.ApplicationConnectorType.MONDAY
+        if isinstance(self.object_type, dict):
+            self.object_type = self.object_type.get('value') or self.object_type.get('name') or self.object_type.get('label')
+        if isinstance(self.object_type, str):
+            normalized_object_type = self.object_type.strip().lower()
+            if normalized_object_type:
+                self.object_type = normalized_object_type
+        if isinstance(self.board_id, dict):
+            self.board_id = self.board_id.get('value') or self.board_id.get('name') or self.board_id.get('label')
+        if self.board_id is not None:
+            self.board_id = str(self.board_id).strip() or None
+
+
 @dataclasses.dataclass
 class DocusignDatasetConfig(ApplicationConnectorDatasetConfig):
     """
@@ -386,5 +412,6 @@ class _ApplicationConnectorDatasetConfigFactory(_ApiClassFactory):
         enums.ApplicationConnectorType.DROPBOX: DropboxDatasetConfig,
         enums.ApplicationConnectorType.HUBSPOT: HubspotDatasetConfig,
         enums.ApplicationConnectorType.QUICKBOOKS: QuickbooksDatasetConfig,
+        enums.ApplicationConnectorType.MONDAY: MondayDatasetConfig,
         enums.ApplicationConnectorType.DOCUSIGN: DocusignDatasetConfig,
     }

abacusai/api_class/enums.py

@@ -930,6 +930,13 @@ class MediaArtifactType(ApiEnum):
     AUDIO = 'AUDIO'
 
 
+class MediaArtifactOrigin(ApiEnum):
+    """How a media artifact entered the gallery."""
+    GENERATED = 'generated'
+    UPLOADED = 'uploaded'
+    EDITOR_EXPORT = 'editor_export'
+
+
 class VerticalType(ApiEnum):
     """Vertical types for specialized external applications."""
     HEALTH = 'HEALTH'

abacusai/client.py

@@ -717,7 +717,7 @@ class BaseApiClient:
         client_options (ClientOptions): Optional API client configurations
         skip_version_check (bool): If true, will skip checking the server's current API version on initializing the client
     """
-    client_version = '1.4.101'
+    client_version = '1.4.102'
 
     def __init__(self, api_key: str = None, server: str = None, client_options: ClientOptions = None, skip_version_check: bool = False, include_tb: bool = False):
         self.api_key = api_key

abacusai/cowork_dispatch_attachment.py

@@ -0,0 +1,41 @@
+from .return_class import AbstractApiClass
+
+
+class CoworkDispatchAttachment(AbstractApiClass):
+    """
+        CoWork desktop file upload result.
+
+        Args:
+            client (ApiClient): An authenticated API Client instance
+            attachmentId (str): Attachment id for downloadAgentAttachment
+            filename (str): Original filename
+            mimeType (str): MIME type of the uploaded file
+            deploymentId (id): Hashed deployment id used for attachment storage lookup
+    """
+
+    def __init__(self, client, attachmentId=None, filename=None, mimeType=None, deploymentId=None):
+        super().__init__(client, None)
+        self.attachment_id = attachmentId
+        self.filename = filename
+        self.mime_type = mimeType
+        self.deployment_id = deploymentId
+        self.deprecated_keys = {}
+
+    def __repr__(self):
+        repr_dict = {f'attachment_id': repr(self.attachment_id), f'filename': repr(
+            self.filename), f'mime_type': repr(self.mime_type), f'deployment_id': repr(self.deployment_id)}
+        class_name = "CoworkDispatchAttachment"
+        repr_str = ',\n  '.join([f'{key}={value}' for key, value in repr_dict.items(
+        ) if getattr(self, key, None) is not None and key not in self.deprecated_keys])
+        return f"{class_name}({repr_str})"
+
+    def to_dict(self):
+        """
+        Get a dict representation of the parameters in this class
+
+        Returns:
+            dict: The dict value representation of the class parameters
+        """
+        resp = {'attachment_id': self.attachment_id, 'filename': self.filename,
+                'mime_type': self.mime_type, 'deployment_id': self.deployment_id}
+        return {key: value for key, value in resp.items() if value is not None and key not in self.deprecated_keys}

abacusai/dataset.py

@@ -37,6 +37,7 @@ class Dataset(AbstractApiClass):
             referenceOnlyDocumentset (bool): Signifies whether to save the data reference only. Only valid if is_documentset if True.
             versionLimit (int): Version limit for the dataset.
             disableRealtimeContentProcessing (bool): Whether realtime content processing is disabled for this dataset (only applicable to REALTIME_CONTENT_STORE datasets).
+            forceFullResync (bool): Whether a complete reindex is pending pickup by the import scheduler (only applicable to REALTIME_CONTENT_STORE datasets).
             realtimeContentStoreConfig (dict): Indexing options (e.g. chunk_size) for the realtime content store (only applicable to REALTIME_CONTENT_STORE datasets).
             latestDatasetVersion (DatasetVersion): The latest version of this dataset.
             schema (DatasetColumn): List of resolved columns.
@@ -46,7 +47,7 @@ class Dataset(AbstractApiClass):
             attachmentParsingConfig (AttachmentParsingConfig): The attachment parsing config used for dataset (eg. for salesforce attachment parsing)
     """
 
-    def __init__(self, client, datasetId=None, sourceType=None, dataSource=None, createdAt=None, ignoreBefore=None, ephemeral=None, lookbackDays=None, databaseConnectorId=None, databaseConnectorConfig=None, connectorType=None, featureGroupTableName=None, applicationConnectorId=None, applicationConnectorConfig=None, incremental=None, isDocumentset=None, extractBoundingBoxes=None, mergeFileSchemas=None, referenceOnlyDocumentset=None, versionLimit=None, disableRealtimeContentProcessing=None, realtimeContentStoreConfig=None, schema={}, refreshSchedules={}, latestDatasetVersion={}, parsingConfig={}, documentProcessingConfig={}, attachmentParsingConfig={}):
+    def __init__(self, client, datasetId=None, sourceType=None, dataSource=None, createdAt=None, ignoreBefore=None, ephemeral=None, lookbackDays=None, databaseConnectorId=None, databaseConnectorConfig=None, connectorType=None, featureGroupTableName=None, applicationConnectorId=None, applicationConnectorConfig=None, incremental=None, isDocumentset=None, extractBoundingBoxes=None, mergeFileSchemas=None, referenceOnlyDocumentset=None, versionLimit=None, disableRealtimeContentProcessing=None, forceFullResync=None, realtimeContentStoreConfig=None, schema={}, refreshSchedules={}, latestDatasetVersion={}, parsingConfig={}, documentProcessingConfig={}, attachmentParsingConfig={}):
         super().__init__(client, datasetId)
         self.dataset_id = datasetId
         self.source_type = sourceType
@@ -68,6 +69,7 @@ def __init__(self, client, datasetId=None, sourceType=None, dataSource=None, cre
         self.reference_only_documentset = referenceOnlyDocumentset
         self.version_limit = versionLimit
         self.disable_realtime_content_processing = disableRealtimeContentProcessing
+        self.force_full_resync = forceFullResync
         self.realtime_content_store_config = realtimeContentStoreConfig
         self.schema = client._build_class(DatasetColumn, schema)
         self.refresh_schedules = client._build_class(
@@ -82,8 +84,8 @@ def __init__(self, client, datasetId=None, sourceType=None, dataSource=None, cre
         self.deprecated_keys = {}
 
     def __repr__(self):
-        repr_dict = {f'dataset_id': repr(self.dataset_id), f'source_type': repr(self.source_type), f'data_source': repr(self.data_source), f'created_at': repr(self.created_at), f'ignore_before': repr(self.ignore_before), f'ephemeral': repr(self.ephemeral), f'lookback_days': repr(self.lookback_days), f'database_connector_id': repr(self.database_connector_id), f'database_connector_config': repr(self.database_connector_config), f'connector_type': repr(self.connector_type), f'feature_group_table_name': repr(self.feature_group_table_name), f'application_connector_id': repr(self.application_connector_id), f'application_connector_config': repr(self.application_connector_config), f'incremental': repr(self.incremental), f'is_documentset': repr(
-            self.is_documentset), f'extract_bounding_boxes': repr(self.extract_bounding_boxes), f'merge_file_schemas': repr(self.merge_file_schemas), f'reference_only_documentset': repr(self.reference_only_documentset), f'version_limit': repr(self.version_limit), f'disable_realtime_content_processing': repr(self.disable_realtime_content_processing), f'realtime_content_store_config': repr(self.realtime_content_store_config), f'schema': repr(self.schema), f'refresh_schedules': repr(self.refresh_schedules), f'latest_dataset_version': repr(self.latest_dataset_version), f'parsing_config': repr(self.parsing_config), f'document_processing_config': repr(self.document_processing_config), f'attachment_parsing_config': repr(self.attachment_parsing_config)}
+        repr_dict = {f'dataset_id': repr(self.dataset_id), f'source_type': repr(self.source_type), f'data_source': repr(self.data_source), f'created_at': repr(self.created_at), f'ignore_before': repr(self.ignore_before), f'ephemeral': repr(self.ephemeral), f'lookback_days': repr(self.lookback_days), f'database_connector_id': repr(self.database_connector_id), f'database_connector_config': repr(self.database_connector_config), f'connector_type': repr(self.connector_type), f'feature_group_table_name': repr(self.feature_group_table_name), f'application_connector_id': repr(self.application_connector_id), f'application_connector_config': repr(self.application_connector_config), f'incremental': repr(self.incremental), f'is_documentset': repr(self.is_documentset), f'extract_bounding_boxes': repr(
+            self.extract_bounding_boxes), f'merge_file_schemas': repr(self.merge_file_schemas), f'reference_only_documentset': repr(self.reference_only_documentset), f'version_limit': repr(self.version_limit), f'disable_realtime_content_processing': repr(self.disable_realtime_content_processing), f'force_full_resync': repr(self.force_full_resync), f'realtime_content_store_config': repr(self.realtime_content_store_config), f'schema': repr(self.schema), f'refresh_schedules': repr(self.refresh_schedules), f'latest_dataset_version': repr(self.latest_dataset_version), f'parsing_config': repr(self.parsing_config), f'document_processing_config': repr(self.document_processing_config), f'attachment_parsing_config': repr(self.attachment_parsing_config)}
         class_name = "Dataset"
         repr_str = ',\n  '.join([f'{key}={value}' for key, value in repr_dict.items(
         ) if getattr(self, key, None) is not None and key not in self.deprecated_keys])
@@ -97,7 +99,7 @@ def to_dict(self):
             dict: The dict value representation of the class parameters
         """
         resp = {'dataset_id': self.dataset_id, 'source_type': self.source_type, 'data_source': self.data_source, 'created_at': self.created_at, 'ignore_before': self.ignore_before, 'ephemeral': self.ephemeral, 'lookback_days': self.lookback_days, 'database_connector_id': self.database_connector_id, 'database_connector_config': self.database_connector_config, 'connector_type': self.connector_type, 'feature_group_table_name': self.feature_group_table_name, 'application_connector_id': self.application_connector_id, 'application_connector_config': self.application_connector_config, 'incremental': self.incremental, 'is_documentset': self.is_documentset, 'extract_bounding_boxes': self.extract_bounding_boxes, 'merge_file_schemas': self.merge_file_schemas,
-                'reference_only_documentset': self.reference_only_documentset, 'version_limit': self.version_limit, 'disable_realtime_content_processing': self.disable_realtime_content_processing, 'realtime_content_store_config': self.realtime_content_store_config, 'schema': self._get_attribute_as_dict(self.schema), 'refresh_schedules': self._get_attribute_as_dict(self.refresh_schedules), 'latest_dataset_version': self._get_attribute_as_dict(self.latest_dataset_version), 'parsing_config': self._get_attribute_as_dict(self.parsing_config), 'document_processing_config': self._get_attribute_as_dict(self.document_processing_config), 'attachment_parsing_config': self._get_attribute_as_dict(self.attachment_parsing_config)}
+                'reference_only_documentset': self.reference_only_documentset, 'version_limit': self.version_limit, 'disable_realtime_content_processing': self.disable_realtime_content_processing, 'force_full_resync': self.force_full_resync, 'realtime_content_store_config': self.realtime_content_store_config, 'schema': self._get_attribute_as_dict(self.schema), 'refresh_schedules': self._get_attribute_as_dict(self.refresh_schedules), 'latest_dataset_version': self._get_attribute_as_dict(self.latest_dataset_version), 'parsing_config': self._get_attribute_as_dict(self.parsing_config), 'document_processing_config': self._get_attribute_as_dict(self.document_processing_config), 'attachment_parsing_config': self._get_attribute_as_dict(self.attachment_parsing_config)}
         return {key: value for key, value in resp.items() if value is not None and key not in self.deprecated_keys}
 
     def get_raw_data_from_realtime(self, check_permissions: bool = False, start_time: str = None, end_time: str = None, column_filter: dict = None):