Version 1.4.60

Author: gyanendra8

abacusai/__init__.py

@@ -32,6 +32,7 @@
 from .chatllm_computer_status import ChatllmComputerStatus
 from .chatllm_memory import ChatllmMemory
 from .chatllm_project import ChatllmProject
+from .chatllm_project_permissions import ChatllmProjectPermissions
 from .chatllm_referral_invite import ChatllmReferralInvite
 from .chatllm_task import ChatllmTask
 from .client import AgentResponse, ApiClient, ApiException, ClientOptions, ReadOnlyClient, ToolResponse, _request_context
@@ -277,4 +278,4 @@
 from .workflow_node_template import WorkflowNodeTemplate
 
 
-__version__ = "1.4.59"
+__version__ = "1.4.60"

abacusai/api_class/enums.py

@@ -419,6 +419,8 @@ class ApplicationConnectorType(ApiEnum):
     SALESFORCE = 'SALESFORCE'
     TWITTER = 'TWITTER'
     MCP = 'MCP'
+    ODBC = 'ODBC'
+    DBC = 'DBC'
 
     @classmethod
     def user_connectors(cls):
@@ -436,11 +438,13 @@ def user_connectors(cls):
             cls.CONFLUENCE,
             cls.BOX,
             cls.GITHUBUSER,
+            cls.ODBC,
+            cls.DBC
         ]
 
     @classmethod
     def database_connectors(cls):
-        return [cls.SALESFORCE]
+        return [cls.SALESFORCE, cls.ODBC, cls.DBC]
 
 
 class StreamingConnectorType(ApiEnum):
@@ -570,7 +574,7 @@ class LLMName(ApiEnum):
     QWEN3_235B_A22B = 'QWEN3_235B_A22B_2507'
     QWEN3_235B_A22B_THINKING = 'QWEN3_235B_A22B_THINKING_2507'
     QWEN3_CODER = 'QWEN3_CODER'
-    DEEPSEEK_V3 = 'DEEPSEEK_V3'
+    DEEPSEEK_V3_1 = 'DEEPSEEK_V3_1'
     DEEPSEEK_R1 = 'DEEPSEEK_R1'
 
 

abacusai/batch_prediction.py

@@ -84,7 +84,7 @@ def __init__(self, client, batchPredictionId=None, createdAt=None, name=None, de
             BatchPredictionArgs, globalPredictionArgs)
         self.batch_prediction_args = client._build_class(getattr(
             api_class, batchPredictionArgsType, BatchPredictionArgs) if batchPredictionArgsType else BatchPredictionArgs, batchPredictionArgs)
-        self.deprecated_keys = {'explanations', 'global_prediction_args'}
+        self.deprecated_keys = {'global_prediction_args', 'explanations'}
 
     def __repr__(self):
         repr_dict = {f'batch_prediction_id': repr(self.batch_prediction_id), f'created_at': repr(self.created_at), f'name': repr(self.name), f'deployment_id': repr(self.deployment_id), f'file_connector_output_location': repr(self.file_connector_output_location), f'database_connector_id': repr(self.database_connector_id), f'database_output_configuration': repr(self.database_output_configuration), f'file_output_format': repr(self.file_output_format), f'connector_type': repr(self.connector_type), f'legacy_input_location': repr(self.legacy_input_location), f'output_feature_group_id': repr(self.output_feature_group_id), f'feature_group_table_name': repr(self.feature_group_table_name), f'output_feature_group_table_name': repr(self.output_feature_group_table_name), f'summary_feature_group_table_name': repr(self.summary_feature_group_table_name), f'csv_input_prefix': repr(

abacusai/batch_prediction_version.py

@@ -100,7 +100,7 @@ def __init__(self, client, batchPredictionVersion=None, batchPredictionId=None,
             BatchPredictionArgs, globalPredictionArgs)
         self.batch_prediction_args = client._build_class(getattr(
             api_class, batchPredictionArgsType, BatchPredictionArgs) if batchPredictionArgsType else BatchPredictionArgs, batchPredictionArgs)
-        self.deprecated_keys = {'explanations', 'global_prediction_args'}
+        self.deprecated_keys = {'global_prediction_args', 'explanations'}
 
     def __repr__(self):
         repr_dict = {f'batch_prediction_version': repr(self.batch_prediction_version), f'batch_prediction_id': repr(self.batch_prediction_id), f'status': repr(self.status), f'drift_monitor_status': repr(self.drift_monitor_status), f'deployment_id': repr(self.deployment_id), f'model_id': repr(self.model_id), f'model_version': repr(self.model_version), f'predictions_started_at': repr(self.predictions_started_at), f'predictions_completed_at': repr(self.predictions_completed_at), f'database_output_error': repr(self.database_output_error), f'total_predictions': repr(self.total_predictions), f'failed_predictions': repr(self.failed_predictions), f'database_connector_id': repr(self.database_connector_id), f'database_output_configuration': repr(self.database_output_configuration), f'file_connector_output_location': repr(self.file_connector_output_location), f'file_output_format': repr(self.file_output_format), f'connector_type': repr(self.connector_type), f'legacy_input_location': repr(self.legacy_input_location), f'error': repr(self.error), f'drift_monitor_error': repr(self.drift_monitor_error), f'monitor_warnings': repr(self.monitor_warnings), f'csv_input_prefix': repr(

abacusai/chatllm_project_permissions.py

@@ -0,0 +1,41 @@
+from .return_class import AbstractApiClass
+
+
+class ChatllmProjectPermissions(AbstractApiClass):
+    """
+        ChatLLM Project Permissions
+
+        Args:
+            client (ApiClient): An authenticated API Client instance
+            chatllmProjectId (id): The ID of the chatllm project.
+            accessLevel (str): The access level of the chatllm project.
+            userPermissions (list): List of tuples containing (user_id, permission).
+            userGroupPermissions (list): List of tuples containing (user_group_id, permission).
+    """
+
+    def __init__(self, client, chatllmProjectId=None, accessLevel=None, userPermissions=None, userGroupPermissions=None):
+        super().__init__(client, None)
+        self.chatllm_project_id = chatllmProjectId
+        self.access_level = accessLevel
+        self.user_permissions = userPermissions
+        self.user_group_permissions = userGroupPermissions
+        self.deprecated_keys = {}
+
+    def __repr__(self):
+        repr_dict = {f'chatllm_project_id': repr(self.chatllm_project_id), f'access_level': repr(
+            self.access_level), f'user_permissions': repr(self.user_permissions), f'user_group_permissions': repr(self.user_group_permissions)}
+        class_name = "ChatllmProjectPermissions"
+        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 = {'chatllm_project_id': self.chatllm_project_id, 'access_level': self.access_level,
+                'user_permissions': self.user_permissions, 'user_group_permissions': self.user_group_permissions}
+        return {key: value for key, value in resp.items() if value is not None and key not in self.deprecated_keys}

abacusai/client.py

@@ -663,7 +663,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.59'
+    client_version = '1.4.60'
 
     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
@@ -2758,7 +2758,7 @@ def list_chat_sessions(self, most_recent_per_project: bool = False) -> ChatSessi
             ChatSession: The chat sessions with Data Science Co-pilot"""
         return self._call_api('listChatSessions', 'GET', query_params={'mostRecentPerProject': most_recent_per_project}, parse_type=ChatSession)
 
-    def get_deployment_conversation(self, deployment_conversation_id: str = None, external_session_id: str = None, deployment_id: str = None, filter_intermediate_conversation_events: bool = True, get_unused_document_uploads: bool = False, start: int = None, limit: int = None) -> DeploymentConversation:
+    def get_deployment_conversation(self, deployment_conversation_id: str = None, external_session_id: str = None, deployment_id: str = None, filter_intermediate_conversation_events: bool = True, get_unused_document_uploads: bool = False, start: int = None, limit: int = None, include_all_versions: bool = False) -> DeploymentConversation:
         """Gets a deployment conversation.
 
         Args:
@@ -2769,10 +2769,11 @@ def get_deployment_conversation(self, deployment_conversation_id: str = None, ex
             get_unused_document_uploads (bool): If true, unused document uploads will be returned. Default is false.
             start (int): The start index of the conversation.
             limit (int): The limit of the conversation.
+            include_all_versions (bool): If True, includes all versions of the last bot message for version switching functionality.
 
         Returns:
             DeploymentConversation: The deployment conversation."""
-        return self._proxy_request('getDeploymentConversation', 'GET', query_params={'deploymentConversationId': deployment_conversation_id, 'externalSessionId': external_session_id, 'deploymentId': deployment_id, 'filterIntermediateConversationEvents': filter_intermediate_conversation_events, 'getUnusedDocumentUploads': get_unused_document_uploads, 'start': start, 'limit': limit}, parse_type=DeploymentConversation, is_sync=True)
+        return self._proxy_request('getDeploymentConversation', 'GET', query_params={'deploymentConversationId': deployment_conversation_id, 'externalSessionId': external_session_id, 'deploymentId': deployment_id, 'filterIntermediateConversationEvents': filter_intermediate_conversation_events, 'getUnusedDocumentUploads': get_unused_document_uploads, 'start': start, 'limit': limit, 'includeAllVersions': include_all_versions}, parse_type=DeploymentConversation, is_sync=True)
 
     def list_deployment_conversations(self, deployment_id: str = None, external_application_id: str = None, conversation_type: Union[DeploymentConversationType, str] = None, fetch_last_llm_info: bool = False, limit: int = None, search: str = None) -> List[DeploymentConversation]:
         """Lists all conversations for the given deployment and current user.
@@ -5276,9 +5277,7 @@ def create_merge_feature_group(self, source_feature_group_id: str, table_name: s
             description (str): Human-readable description of this feature group.
 
         Returns:
-            FeatureGroup: The created feature group.
-Description:
-Creates a new feature group defined as the union of other feature group versions."""
+            FeatureGroup: The created feature group."""
         return self._call_api('createMergeFeatureGroup', 'POST', query_params={}, body={'sourceFeatureGroupId': source_feature_group_id, 'tableName': table_name, 'mergeConfig': merge_config, 'description': description}, parse_type=FeatureGroup)
 
     def create_operator_feature_group(self, source_feature_group_id: str, table_name: str, operator_config: Union[dict, OperatorConfig], description: str = None) -> FeatureGroup:

abacusai/deployment_conversation.py

@@ -96,7 +96,7 @@ def to_dict(self):
                 'metadata': self.metadata, 'llm_display_name': self.llm_display_name, 'llm_bot_icon': self.llm_bot_icon, 'search_suggestions': self.search_suggestions, 'chatllm_task_id': self.chatllm_task_id, 'conversation_status': self.conversation_status, 'computer_status': self.computer_status, 'total_events': self.total_events, 'contest_names': self.contest_names, 'daemon_task_id': self.daemon_task_id, 'parent_deployment_conversation_id': self.parent_deployment_conversation_id, 'intro_message': self.intro_message, 'preview_info': self.preview_info, 'history': self._get_attribute_as_dict(self.history), 'hosted_artifacts': self._get_attribute_as_dict(self.hosted_artifacts)}
         return {key: value for key, value in resp.items() if value is not None and key not in self.deprecated_keys}
 
-    def get(self, external_session_id: str = None, deployment_id: str = None, filter_intermediate_conversation_events: bool = True, get_unused_document_uploads: bool = False, start: int = None, limit: int = None):
+    def get(self, external_session_id: str = None, deployment_id: str = None, filter_intermediate_conversation_events: bool = True, get_unused_document_uploads: bool = False, start: int = None, limit: int = None, include_all_versions: bool = False):
         """
         Gets a deployment conversation.
 
@@ -107,11 +107,12 @@ def get(self, external_session_id: str = None, deployment_id: str = None, filter
             get_unused_document_uploads (bool): If true, unused document uploads will be returned. Default is false.
             start (int): The start index of the conversation.
             limit (int): The limit of the conversation.
+            include_all_versions (bool): If True, includes all versions of the last bot message for version switching functionality.
 
         Returns:
             DeploymentConversation: The deployment conversation.
         """
-        return self.client.get_deployment_conversation(self.deployment_conversation_id, external_session_id, deployment_id, filter_intermediate_conversation_events, get_unused_document_uploads, start, limit)
+        return self.client.get_deployment_conversation(self.deployment_conversation_id, external_session_id, deployment_id, filter_intermediate_conversation_events, get_unused_document_uploads, start, limit, include_all_versions)
 
     def delete(self, deployment_id: str = None):
         """