Version 1.4.114

Author: gyanendra8

abacusai/__init__.py

@@ -207,6 +207,7 @@
 from .memory_options import MemoryOptions
 from .messaging_connector_response import MessagingConnectorResponse
 from .mobile_app_build_status import MobileAppBuildStatus
+from .mobile_app_identifiers import MobileAppIdentifiers
 from .mobile_build_info import MobileBuildInfo
 from .model import Model
 from .model_artifacts_export import ModelArtifactsExport
@@ -342,8 +343,9 @@
 from .web_search_result import WebSearchResult
 from .web_service_trigger_run import WebServiceTriggerRun
 from .webhook import Webhook
+from .whatsapp_referral_invite import WhatsappReferralInvite
 from .workflow_graph_node_details import WorkflowGraphNodeDetails
 from .workflow_node_template import WorkflowNodeTemplate
 
 
-__version__ = "1.4.113"
+__version__ = "1.4.114"

abacusai/ad_template.py

@@ -18,9 +18,10 @@ class AdTemplate(AbstractApiClass):
             cardDescription (str): Two-line description of the video the format makes, for its preview dialog
             description (str): Gallery caption / display copy
             exampleMedia (list): CDN URLs of preview videos for the card
+            exampleMediaPreview (list): Compressed 480p encodes of example_media, for the card walls
     """
 
-    def __init__(self, client, slug=None, name=None, category=None, supportsAvatar=None, needsProduct=None, defaultDuration=None, defaultAspectRatio=None, cardOneLiner=None, cardDescription=None, description=None, exampleMedia=None):
+    def __init__(self, client, slug=None, name=None, category=None, supportsAvatar=None, needsProduct=None, defaultDuration=None, defaultAspectRatio=None, cardOneLiner=None, cardDescription=None, description=None, exampleMedia=None, exampleMediaPreview=None):
         super().__init__(client, None)
         self.slug = slug
         self.name = name
@@ -33,11 +34,12 @@ def __init__(self, client, slug=None, name=None, category=None, supportsAvatar=N
         self.card_description = cardDescription
         self.description = description
         self.example_media = exampleMedia
+        self.example_media_preview = exampleMediaPreview
         self.deprecated_keys = {}
 
     def __repr__(self):
-        repr_dict = {f'slug': repr(self.slug), f'name': repr(self.name), f'category': repr(self.category), f'supports_avatar': repr(self.supports_avatar), f'needs_product': repr(self.needs_product), f'default_duration': repr(
-            self.default_duration), f'default_aspect_ratio': repr(self.default_aspect_ratio), f'card_one_liner': repr(self.card_one_liner), f'card_description': repr(self.card_description), f'description': repr(self.description), f'example_media': repr(self.example_media)}
+        repr_dict = {f'slug': repr(self.slug), f'name': repr(self.name), f'category': repr(self.category), f'supports_avatar': repr(self.supports_avatar), f'needs_product': repr(self.needs_product), f'default_duration': repr(self.default_duration), f'default_aspect_ratio': repr(
+            self.default_aspect_ratio), f'card_one_liner': repr(self.card_one_liner), f'card_description': repr(self.card_description), f'description': repr(self.description), f'example_media': repr(self.example_media), f'example_media_preview': repr(self.example_media_preview)}
         class_name = "AdTemplate"
         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])
@@ -50,6 +52,6 @@ def to_dict(self):
         Returns:
             dict: The dict value representation of the class parameters
         """
-        resp = {'slug': self.slug, 'name': self.name, 'category': self.category, 'supports_avatar': self.supports_avatar, 'needs_product': self.needs_product, 'default_duration': self.default_duration,
-                'default_aspect_ratio': self.default_aspect_ratio, 'card_one_liner': self.card_one_liner, 'card_description': self.card_description, 'description': self.description, 'example_media': self.example_media}
+        resp = {'slug': self.slug, 'name': self.name, 'category': self.category, 'supports_avatar': self.supports_avatar, 'needs_product': self.needs_product, 'default_duration': self.default_duration, 'default_aspect_ratio': self.default_aspect_ratio,
+                'card_one_liner': self.card_one_liner, 'card_description': self.card_description, 'description': self.description, 'example_media': self.example_media, 'example_media_preview': self.example_media_preview}
         return {key: value for key, value in resp.items() if value is not None and key not in self.deprecated_keys}

abacusai/agent_network.py

@@ -10,7 +10,7 @@ class AgentNetwork(AbstractApiClass):
             discoverable (bool): Whether teammates in the org can find this agent and request a contact.
             orgHasOtherUsers (bool): Whether the owner's org has other users (teammate controls are shown only then).
             ownAgents (list): The owner's other agents (bot_id/name/description); always reachable.
-            contacts (list): Teammate agents (bot_id/name/description/owner_user_id/owner_name/status/t); status is PENDING_IN, PENDING_OUT or ACCEPTED.
+            contacts (list): Other people's agents (bot_id/name/owner_user_id/owner_name/status/t/org_id/external); status is PENDING_IN, PENDING_OUT or ACCEPTED; external agents live in another org (org_id set) and may be on another cluster.
     """
 
     def __init__(self, client, discoverable=None, orgHasOtherUsers=None, ownAgents=None, contacts=None):

abacusai/agent_skill.py

@@ -26,7 +26,7 @@ class AgentSkill(AbstractApiClass):
             shareCount (int): Number of people an owned skill is shared with.
             sharedStoreDir (str): Directory name of the viewer's own copy of a shared skill, present once they opt in.
             hashedAgentSkillId (str): Hashed skill id used by skill share links.
-            userDisabled (bool): Whether the user explicitly disabled this system skill, keeping it listed instead of returning it to the import library.
+            userDisabled (bool): Whether this system skill, or (in a project listing) this linked user skill, was explicitly disabled in the listed scope, keeping it listed instead of returning it to the import library.
             usedByTasks (bool): Whether any of the user's daemon tasks reference this skill, so disabling it will ask for confirmation.
     """
 

abacusai/api_class/ai_agents.py

@@ -751,6 +751,7 @@ def to_dict(self):
 
     @classmethod
     def from_dict(cls, node: dict):
+        validate_input_dict_param(node, friendly_class_name='decision_node', must_contain=['name', 'source_code'])
         return cls(
             name=node['name'],
             condition=node['source_code'],
@@ -829,6 +830,7 @@ def to_dict(self):
 
     @classmethod
     def from_dict(cls, node: dict):
+        validate_input_dict_param(node, friendly_class_name='llm_agent_node', must_contain=['name', 'chatbot_deployment_id', 'chatbot_parameters'])
         instance = cls(
             name=node['name'],
             chatbot_deployment_id=node['chatbot_deployment_id'],

abacusai/api_class/enums.py

@@ -605,7 +605,7 @@ class VectorStoreTextEncoder(ApiEnum):
                   'LLAMA3_LARGE_CHAT', 'LLAMA3_1_405B', 'LLAMA3_1_70B', 'LLAMA3_1_8B', 'LLAMA3_3_70B', 'LLAMA4_MAVERICK',
                   'QWEN_2_5_32B_BASE', 'QWEN_2_5_32B', 'QWEN_2_5_72B', 'QWQ_32B',
                   'DEEPSEEK_V3_1', 'DEEPSEEK_R1',
-                  'ZAI_GLM_5_1', 'OX_ALPHA', 'ABACUS_DRACARYS',
+                  'ZAI_GLM_5_1', 'OX_ALPHA', 'UNION_ALPHA', 'ABACUS_DRACARYS',
                   )
 class LLMName(ApiEnum):
     OPENAI_GPT3_5 = 'OPENAI_GPT3_5'
@@ -655,6 +655,8 @@ class LLMName(ApiEnum):
     CLAUDE_V4_7_OPUS = 'CLAUDE_V4_7_OPUS'
     CLAUDE_V4_8_OPUS = 'CLAUDE_V4_8_OPUS'
     CLAUDE_V5_OPUS = 'CLAUDE_V5_OPUS'
+    CLAUDE_V5_FABLE = 'CLAUDE_V5_FABLE'
+    CLAUDE_V5_1_FABLE = 'CLAUDE_V5_1_FABLE'
     GEMINI_1_5_PRO = 'GEMINI_1_5_PRO'
     GEMINI_1_5_FLASH = 'GEMINI_1_5_FLASH'
     GEMINI_2_PRO = 'GEMINI_2_PRO'
@@ -718,6 +720,7 @@ class LLMName(ApiEnum):
     KIMI_K3 = 'KIMI_K3'
     INKLING = 'INKLING'
     OX_ALPHA = 'OX_ALPHA'
+    UNION_ALPHA = 'UNION_ALPHA'
 
 
 class MonitorAlertType(ApiEnum):

abacusai/app_user_group.py

@@ -17,7 +17,7 @@ class AppUserGroup(AbstractApiClass):
             isExternalServiceGroup (bool): Whether the App User Group corresponds to a user group that's defined in an external service (i.e Microsft Active Directory or Okta) or not
             externalServiceGroupId (str): The identifier that corresponds to the app user group's external service group representation
             creationSource (str): The source of the app user group
-            users (User): The users in the user group.
+            users (User): The users in the user group. Each carries a `status` of `ACTIVE` or `PAUSED`.
     """
 
     def __init__(self, client, name=None, userGroupId=None, externalApplicationIds=None, invitedUserEmails=None, publicUserGroup=None, hasExternalApplicationReporting=None, isExternalServiceGroup=None, externalServiceGroupId=None, creationSource=None, users={}):

abacusai/bot_channel_options.py

@@ -10,18 +10,20 @@ class BotChannelOptions(AbstractApiClass):
             sharedChannels (list): Channels this cluster runs a shared Abacus bot for, so they link by QR / deep link with no user-supplied tokens.
             telegramBotUsername (str): The shared Telegram bot's username, when there is one.
             channels (list): Every supported channel: channel, label, whether it is shared, whether the 'use your own bot' screen should offer it (offers_own_bot), and the credential form it takes (credential_fields: key/label/secret, in display order).
+            slackWorkspace (dict): The admin-installed Slack workspace personal agents can be reached from (team_id, workspace_name, linked: whether this user tied their Slack account to Abacus.AI), when the org has one.
     """
 
-    def __init__(self, client, sharedChannels=None, telegramBotUsername=None, channels=None):
+    def __init__(self, client, sharedChannels=None, telegramBotUsername=None, channels=None, slackWorkspace=None):
         super().__init__(client, None)
         self.shared_channels = sharedChannels
         self.telegram_bot_username = telegramBotUsername
         self.channels = channels
+        self.slack_workspace = slackWorkspace
         self.deprecated_keys = {}
 
     def __repr__(self):
         repr_dict = {f'shared_channels': repr(self.shared_channels), f'telegram_bot_username': repr(
-            self.telegram_bot_username), f'channels': repr(self.channels)}
+            self.telegram_bot_username), f'channels': repr(self.channels), f'slack_workspace': repr(self.slack_workspace)}
         class_name = "BotChannelOptions"
         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])
@@ -34,6 +36,6 @@ def to_dict(self):
         Returns:
             dict: The dict value representation of the class parameters
         """
-        resp = {'shared_channels': self.shared_channels,
-                'telegram_bot_username': self.telegram_bot_username, 'channels': self.channels}
+        resp = {'shared_channels': self.shared_channels, 'telegram_bot_username': self.telegram_bot_username,
+                'channels': self.channels, 'slack_workspace': self.slack_workspace}
         return {key: value for key, value in resp.items() if value is not None and key not in self.deprecated_keys}

abacusai/chatllm_referral_invite.py

@@ -10,18 +10,22 @@ class ChatllmReferralInvite(AbstractApiClass):
             userAlreadyExists (list): List of user emails not successfullt invited, because they are already registered users.
             successfulInvites (list): List of users successfully invited.
             failedToSend (list): Emails whose invite could not be sent from the user's Gmail account.
+            invitesSent (int): The user's total invites on record after this call (AbacusAI Bot invites only).
+            milestoneCreditsGranted (int): Credits granted by this call when it crossed the invite milestone, else 0 (AbacusAI Bot invites only).
     """
 
-    def __init__(self, client, userAlreadyExists=None, successfulInvites=None, failedToSend=None):
+    def __init__(self, client, userAlreadyExists=None, successfulInvites=None, failedToSend=None, invitesSent=None, milestoneCreditsGranted=None):
         super().__init__(client, None)
         self.user_already_exists = userAlreadyExists
         self.successful_invites = successfulInvites
         self.failed_to_send = failedToSend
+        self.invites_sent = invitesSent
+        self.milestone_credits_granted = milestoneCreditsGranted
         self.deprecated_keys = {}
 
     def __repr__(self):
-        repr_dict = {f'user_already_exists': repr(self.user_already_exists), f'successful_invites': repr(
-            self.successful_invites), f'failed_to_send': repr(self.failed_to_send)}
+        repr_dict = {f'user_already_exists': repr(self.user_already_exists), f'successful_invites': repr(self.successful_invites), f'failed_to_send': repr(
+            self.failed_to_send), f'invites_sent': repr(self.invites_sent), f'milestone_credits_granted': repr(self.milestone_credits_granted)}
         class_name = "ChatllmReferralInvite"
         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])
@@ -34,6 +38,6 @@ def to_dict(self):
         Returns:
             dict: The dict value representation of the class parameters
         """
-        resp = {'user_already_exists': self.user_already_exists,
-                'successful_invites': self.successful_invites, 'failed_to_send': self.failed_to_send}
+        resp = {'user_already_exists': self.user_already_exists, 'successful_invites': self.successful_invites,
+                'failed_to_send': self.failed_to_send, 'invites_sent': self.invites_sent, 'milestone_credits_granted': self.milestone_credits_granted}
         return {key: value for key, value in resp.items() if value is not None and key not in self.deprecated_keys}

abacusai/client.py

@@ -716,7 +716,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.113'
+    client_version = '1.4.114'
 
     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
@@ -747,8 +747,9 @@ def __init__(self, api_key: str = None, server: str = None, client_options: Clie
                     endpoint_info = self._call_api('getApiEndpoint', 'GET')
                     self.prediction_endpoint = endpoint_info['predictEndpoint']
                     self.proxy_endpoint = endpoint_info.get('proxyEndpoint')
+                    self.api_endpoint = endpoint_info['apiEndpoint']
                     if not self.server:
-                        self.server = endpoint_info['apiEndpoint']
+                        self.server = self.api_endpoint
                     break
                 except Exception as e:
                     logging.warning(f'Error while calling API: {e}')
@@ -761,15 +762,16 @@ def __init__(self, api_key: str = None, server: str = None, client_options: Clie
             'g')
         if not skip_version_check:
             try:
-                self.web_version = self._call_api('version', 'GET')
+                self.web_version = self._call_api(
+                    'version', 'GET', server_override=self.api_endpoint)
                 if version.parse(self.web_version) > version.parse(self.client_version):
                     warnings.warn(
                         'A new version of the Abacus.AI library is available')
                     warnings.warn(
                         f'Current Version: {self.client_version} -> New Version: {self.web_version}')
             except Exception:
                 logging.error(
-                    f'Failed get the current API version from Abacus.AI ({self.server or DEFAULT_SERVER}/api/v0/version)')
+                    f'Failed get the current API version from Abacus.AI ({self.api_endpoint or self.server or DEFAULT_SERVER}/api/v0/version)')
         # Modify traceback
         if not include_tb:
             excepthook = sys.excepthook
@@ -4729,7 +4731,7 @@ def _get_doc_retriever_deployment_info(self, document_retriever_id: str):
         @lru_cache()
         def _cached_doc_retriever_deployment_info(document_retriever_id: str, ttl_hash: int):
             info = self._call_api('_getDocRetrieverDeploymentInfo', 'GET', query_params={
-                                  'documentRetrieverId': document_retriever_id})
+                                  'documentRetrieverId': document_retriever_id}, server_override=self.api_endpoint)
             deployment_token = info['deploymentToken']
             deployment_id = info['deploymentId']
             return deployment_token, deployment_id