Version 1.4.76

Author: gyanendra8

abacusai/__init__.py

@@ -286,9 +286,10 @@
 from .web_page_response import WebPageResponse
 from .web_search_response import WebSearchResponse
 from .web_search_result import WebSearchResult
+from .web_service_trigger_run import WebServiceTriggerRun
 from .webhook import Webhook
 from .workflow_graph_node_details import WorkflowGraphNodeDetails
 from .workflow_node_template import WorkflowNodeTemplate
 
 
-__version__ = "1.4.75"
+__version__ = "1.4.76"

abacusai/api_class/ai_agents.py

@@ -223,18 +223,25 @@ def from_tool_variable_mappings(cls, tool_variable_mappings: dict):
         Args:
             tool_variable_mappings (List[dict]): The tool variable mappings for the node.
         """
-        json_schema = {'type': 'object', 'properties': {}}
+        json_schema = {'type': 'object', 'properties': {}, 'required': []}
+        ui_schema = {}
         for mapping in tool_variable_mappings:
             json_schema['properties'][mapping['name']] = {'title': mapping['name'], 'type': enums.PythonFunctionArgumentType.to_json_type(mapping['variable_type'])}
             if mapping.get('description'):
                 json_schema['properties'][mapping['name']]['description'] = mapping['description']
             if mapping['variable_type'] == enums.PythonFunctionArgumentType.ATTACHMENT:
                 json_schema['properties'][mapping['name']]['format'] = 'data-url'
+                ui_schema[mapping['name']] = {'ui:widget': 'file'}
             if mapping['variable_type'] == enums.PythonFunctionArgumentType.LIST:
-                json_schema['properties'][mapping['name']]['items'] = {'type': enums.PythonFunctionArgumentType.to_json_type(mapping['item_type'])}
                 if mapping['item_type'] == enums.PythonFunctionArgumentType.ATTACHMENT:
-                    json_schema['properties'][mapping['name']]['items']['format'] = 'data-url'
-        return cls(json_schema=json_schema)
+                    json_schema['properties'][mapping['name']]['type'] = 'string'
+                    json_schema['properties'][mapping['name']]['format'] = 'data-url'
+                    ui_schema[mapping['name']] = {'ui:widget': 'file', 'ui:options': {'multiple': True}}
+                else:
+                    json_schema['properties'][mapping['name']]['items'] = {'type': enums.PythonFunctionArgumentType.to_json_type(mapping['item_type'])}
+            if mapping['is_required']:
+                json_schema['required'].append(mapping['name'])
+        return cls(json_schema=json_schema, ui_schema=ui_schema)
 
 
 @validate_constructor_arg_types('output_mapping')
@@ -756,29 +763,18 @@ def __init__(self, name: str, chatbot_deployment_id: str = None, chatbot_paramet
 
         # Prepare input and output mappings
         input_mappings = [
-            WorkflowNodeInputMapping(name='user_input', variable_type=enums.WorkflowNodeInputType.USER_INPUT, is_required=True),
-            WorkflowNodeInputMapping(name='attachment_input', variable_type=enums.WorkflowNodeInputType.USER_INPUT, is_required=False, description='Optional file attachment to include with the message')
+            WorkflowNodeInputMapping(name='user_input', variable_type=enums.WorkflowNodeInputType.USER_INPUT, is_required=True)
         ]
         output_mappings = [WorkflowNodeOutputMapping(name='chat_output', variable_type=enums.WorkflowNodeOutputType.DICT, description='The output of the chatbot')]
 
         # Determine function_name and create minimal source_code for parent validation
         # Always use get_function_name() which includes uid to ensure uniqueness
         function_name = self.get_function_name()
-        minimal_source_code = f'def {function_name}(user_input, attachment_input=None):\n    pass'
+        minimal_source_code = f'def {function_name}(user_input):\n    pass'
 
-        # Customize input schema to mark attachment_input as a file type
+        # Generate input schema from input mappings if not provided
         if input_schema is None:
-            base_schema = WorkflowNodeInputSchema.from_input_mappings(input_mappings)
-            # Override attachment_input to be a file format in json_schema
-            if base_schema.json_schema.get('properties', {}).get('attachment_input'):
-                base_schema.json_schema['properties']['attachment_input']['type'] = 'string'
-                base_schema.json_schema['properties']['attachment_input']['format'] = 'data-url'
-                base_schema.json_schema['properties']['attachment_input']['description'] = 'Optional file attachment to include with the message'
-            # Set ui_schema to use file widget for attachment_input
-            if not base_schema.ui_schema:
-                base_schema.ui_schema = {}
-            base_schema.ui_schema['attachment_input'] = {'ui:widget': 'file'}
-            input_schema = base_schema
+            input_schema = WorkflowNodeInputSchema.from_input_mappings(input_mappings)
 
         # Initialize parent class with minimal source code to satisfy validation
         super().__init__(name=name, function_name=function_name, source_code=minimal_source_code, input_mappings=input_mappings, output_mappings=output_mappings, input_schema=input_schema, output_schema=output_schema or WorkflowNodeOutputSchema.from_fields_list(['chat_output']))
@@ -882,8 +878,8 @@ def _mark_file_inputs_in_schema(input_schema: WorkflowNodeInputSchema) -> None:
                 prop_schema['format'] = 'data-url'
                 input_schema.ui_schema[prop_name] = {'ui:widget': 'file'}
 
-    def __init__(self, name: str, input_mappings: Union[Dict[str, WorkflowNodeInputMapping], List[WorkflowNodeInputMapping]] = None, output_mappings: Union[List[str], Dict[str, str], List[WorkflowNodeOutputMapping]] = None, input_schema: WorkflowNodeInputSchema = None, output_schema: WorkflowNodeOutputSchema = None, description: str = None):
-        self.uid = str(uuid.uuid4())[:6]
+    def __init__(self, name: str, input_mappings: Union[Dict[str, WorkflowNodeInputMapping], List[WorkflowNodeInputMapping]] = None, output_mappings: Union[List[str], Dict[str, str], List[WorkflowNodeOutputMapping]] = None, input_schema: WorkflowNodeInputSchema = None, output_schema: WorkflowNodeOutputSchema = None, description: str = None, function_name: str = None, source_code: str = None, uid: str = None):
+        self.uid = uid or str(uuid.uuid4())[:6]
 
         if input_mappings is None:
             input_mappings = [
@@ -909,7 +905,7 @@ def __init__(self, name: str, input_mappings: Union[Dict[str, WorkflowNodeInputM
                 )
             ]
 
-        function_name = self.get_function_name()
+        function_name = function_name or self.get_function_name()
 
         if input_schema is None:
             input_schema = WorkflowNodeInputSchema.from_input_mappings(input_mappings)
@@ -937,15 +933,15 @@ def __init__(self, name: str, input_mappings: Union[Dict[str, WorkflowNodeInputM
         super().__init__(
             name=name,
             function_name=function_name,
-            source_code=None,
+            source_code=source_code,
             input_mappings=input_mappings,
             output_mappings=output_mappings,
             input_schema=input_schema,
             output_schema=output_schema,
             description=description
         )
         self.node_type = 'input_node'
-        self.source_code = None
+        self.source_code = source_code
         self.template_metadata = None
         self.trigger_config = None
 
@@ -972,34 +968,29 @@ def to_dict(self):
 
     @classmethod
     def from_dict(cls, node: dict):
+        uid = node.get('uid')
+        function_name = node.get('function_name')
+        source_code = node.get('source_code')
+
         instance = cls(
             name=node['name'],
+            uid=uid,
+            function_name=function_name,
+            source_code=source_code,
             input_mappings=[WorkflowNodeInputMapping.from_dict(mapping) for mapping in node.get('input_mappings', [])],
             output_mappings=[WorkflowNodeOutputMapping.from_dict(mapping) for mapping in node.get('output_mappings', [])],
             input_schema=WorkflowNodeInputSchema.from_dict(node.get('input_schema', {})),
             output_schema=WorkflowNodeOutputSchema.from_dict(node.get('output_schema', {})),
             description=node.get('description'),
         )
-        # Preserve uid from dict if it exists (for round-trip serialization of existing workflows)
-        if 'uid' in node and node.get('uid'):
-            instance.uid = node['uid']
-            # Regenerate function_name with preserved uid
-            instance.function_name = f'input_node_{instance.uid}'
-            # Regenerate source_code so it matches the preserved uid/function_name
-            instance.source_code = instance.get_source_code()
         return instance
 
     def get_function_name(self):
         return f'input_node_{self.uid}'
 
     def get_source_code(self):
-        """Return None for input node source code.
-
-        Input nodes are executed directly without source code validation,
-        similar to LLM agent nodes. The minimal source code is only used during
-        initialization to satisfy parent class validation.
-        """
-        return None
+        """Return the stored source code, if any."""
+        return self.source_code
 
     def get_input_schema(self):
         return self.input_schema

abacusai/api_class/enums.py

@@ -566,6 +566,7 @@ class LLMName(ApiEnum):
     GEMINI_2_5_PRO = 'GEMINI_2_5_PRO'
     GEMINI_3_PRO = 'GEMINI_3_PRO'
     GEMINI_2_5_FLASH = 'GEMINI_2_5_FLASH'
+    GEMINI_3_FLASH = 'GEMINI_3_FLASH'
     XAI_GROK = 'XAI_GROK'
     XAI_GROK_3 = 'XAI_GROK_3'
     XAI_GROK_3_MINI = 'XAI_GROK_3_MINI'

abacusai/chatllm_task.py

@@ -12,6 +12,7 @@ class ChatllmTask(AbstractApiClass):
             taskType (str): The type of task ('chatllm' or 'daemon').
             name (str): The name of the chatllm task.
             instructions (str): The instructions of the chatllm task.
+            description (str): The description of the chatllm task.
             lifecycle (str): The lifecycle of the chatllm task.
             scheduleInfo (dict): The schedule info of the chatllm task.
             externalApplicationId (str): The external application id associated with the chatllm task.
@@ -23,15 +24,18 @@ class ChatllmTask(AbstractApiClass):
             computePointsUsed (int): The compute points used for the chatllm task.
             displayMarkdown (str): The display markdown for the chatllm task.
             requiresNewConversation (bool): Whether a new conversation is required for the chatllm task.
+            executionMode (str): The execution mode of the chatllm task.
+            taskDefinition (dict): The task definition (for web_service_trigger tasks).
     """
 
-    def __init__(self, client, chatllmTaskId=None, daemonTaskId=None, taskType=None, name=None, instructions=None, lifecycle=None, scheduleInfo=None, externalApplicationId=None, deploymentConversationId=None, sourceDeploymentConversationId=None, enableEmailAlerts=None, email=None, numUnreadTaskInstances=None, computePointsUsed=None, displayMarkdown=None, requiresNewConversation=None):
+    def __init__(self, client, chatllmTaskId=None, daemonTaskId=None, taskType=None, name=None, instructions=None, description=None, lifecycle=None, scheduleInfo=None, externalApplicationId=None, deploymentConversationId=None, sourceDeploymentConversationId=None, enableEmailAlerts=None, email=None, numUnreadTaskInstances=None, computePointsUsed=None, displayMarkdown=None, requiresNewConversation=None, executionMode=None, taskDefinition=None):
         super().__init__(client, chatllmTaskId)
         self.chatllm_task_id = chatllmTaskId
         self.daemon_task_id = daemonTaskId
         self.task_type = taskType
         self.name = name
         self.instructions = instructions
+        self.description = description
         self.lifecycle = lifecycle
         self.schedule_info = scheduleInfo
         self.external_application_id = externalApplicationId
@@ -43,11 +47,13 @@ def __init__(self, client, chatllmTaskId=None, daemonTaskId=None, taskType=None,
         self.compute_points_used = computePointsUsed
         self.display_markdown = displayMarkdown
         self.requires_new_conversation = requiresNewConversation
+        self.execution_mode = executionMode
+        self.task_definition = taskDefinition
         self.deprecated_keys = {}
 
     def __repr__(self):
-        repr_dict = {f'chatllm_task_id': repr(self.chatllm_task_id), f'daemon_task_id': repr(self.daemon_task_id), f'task_type': repr(self.task_type), f'name': repr(self.name), f'instructions': repr(self.instructions), f'lifecycle': repr(self.lifecycle), f'schedule_info': repr(self.schedule_info), f'external_application_id': repr(self.external_application_id), f'deployment_conversation_id': repr(
-            self.deployment_conversation_id), f'source_deployment_conversation_id': repr(self.source_deployment_conversation_id), f'enable_email_alerts': repr(self.enable_email_alerts), f'email': repr(self.email), f'num_unread_task_instances': repr(self.num_unread_task_instances), f'compute_points_used': repr(self.compute_points_used), f'display_markdown': repr(self.display_markdown), f'requires_new_conversation': repr(self.requires_new_conversation)}
+        repr_dict = {f'chatllm_task_id': repr(self.chatllm_task_id), f'daemon_task_id': repr(self.daemon_task_id), f'task_type': repr(self.task_type), f'name': repr(self.name), f'instructions': repr(self.instructions), f'description': repr(self.description), f'lifecycle': repr(self.lifecycle), f'schedule_info': repr(self.schedule_info), f'external_application_id': repr(self.external_application_id), f'deployment_conversation_id': repr(self.deployment_conversation_id), f'source_deployment_conversation_id': repr(
+            self.source_deployment_conversation_id), f'enable_email_alerts': repr(self.enable_email_alerts), f'email': repr(self.email), f'num_unread_task_instances': repr(self.num_unread_task_instances), f'compute_points_used': repr(self.compute_points_used), f'display_markdown': repr(self.display_markdown), f'requires_new_conversation': repr(self.requires_new_conversation), f'execution_mode': repr(self.execution_mode), f'task_definition': repr(self.task_definition)}
         class_name = "ChatllmTask"
         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])
@@ -60,6 +66,6 @@ def to_dict(self):
         Returns:
             dict: The dict value representation of the class parameters
         """
-        resp = {'chatllm_task_id': self.chatllm_task_id, 'daemon_task_id': self.daemon_task_id, 'task_type': self.task_type, 'name': self.name, 'instructions': self.instructions, 'lifecycle': self.lifecycle, 'schedule_info': self.schedule_info, 'external_application_id': self.external_application_id, 'deployment_conversation_id': self.deployment_conversation_id,
-                'source_deployment_conversation_id': self.source_deployment_conversation_id, 'enable_email_alerts': self.enable_email_alerts, 'email': self.email, 'num_unread_task_instances': self.num_unread_task_instances, 'compute_points_used': self.compute_points_used, 'display_markdown': self.display_markdown, 'requires_new_conversation': self.requires_new_conversation}
+        resp = {'chatllm_task_id': self.chatllm_task_id, 'daemon_task_id': self.daemon_task_id, 'task_type': self.task_type, 'name': self.name, 'instructions': self.instructions, 'description': self.description, 'lifecycle': self.lifecycle, 'schedule_info': self.schedule_info, 'external_application_id': self.external_application_id, 'deployment_conversation_id': self.deployment_conversation_id,
+                'source_deployment_conversation_id': self.source_deployment_conversation_id, 'enable_email_alerts': self.enable_email_alerts, 'email': self.email, 'num_unread_task_instances': self.num_unread_task_instances, 'compute_points_used': self.compute_points_used, 'display_markdown': self.display_markdown, 'requires_new_conversation': self.requires_new_conversation, 'execution_mode': self.execution_mode, 'task_definition': self.task_definition}
         return {key: value for key, value in resp.items() if value is not None and key not in self.deprecated_keys}

abacusai/client.py

@@ -667,7 +667,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.75'
+    client_version = '1.4.76'
 
     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