feat: autonomous error tracking and memory management

CHANGELOG.md

@@ -1,4 +1,27 @@
-## v0.8.38 - 2025-01-31
+## v0.8.39 - 2026-01-04
+
+### Features
+- **Safe Smart Wallet Integration**: Implemented Safe smart wallet functionality with Privy wallet provider for enhanced security and multi-signature support
+- **Agent Activity & Post Modules**: Added comprehensive agent activity and post modules with complete models, core logic, and unit tests
+- **System Skills**: Introduced system skills for creating posts and activities, enabling agents to interact with the platform
+- **Skill Call Agent**: Implemented skill call agent functionality with improved error handling and validation
+- **Default System Skills**: System skills are now included by default for all agents
+
+### Improvements
+- **Unified Agent API Router**: Refactored auth and openai_compatible endpoints into a unified agent_api router for better organization
+- **Better Error Handling**: Enhanced error messages and handling in call agent skill
+- **Agent Post Skill**: Improved agent post skill functionality
+
+### Testing
+- Added comprehensive unit tests for template functions including `create_template_from_agent` and `render_agent`
+
+### Maintenance
+- Upgraded dependencies to latest versions
+- Fixed various lint issues
+
+**Full Changelog**: https://github.com/crestalnetwork/intentkit/compare/v0.8.38...v0.8.39
+
+## v0.8.38 - 2025-12-31
 
 ### Features
 - **Template System**: Added comprehensive agent template functionality
@@ -20,7 +43,7 @@
 
 **Full Changelog**: https://github.com/crestalnetwork/intentkit/compare/v0.8.37...v0.8.38
 
-## v0.8.37 - 2025-01-27
+## v0.8.37 - 2025-12-27
 
 ### Features
 - Frontend skill box display in chat interface
@@ -37,7 +60,7 @@
 
 **Full Changelog**: https://github.com/crestalnetwork/intentkit/compare/v0.8.36...v0.8.37
 
-## v0.8.35 - 2025-01-30
+## v0.8.35 - 2025-11-30
 
 ### Features
 - Add GPT-5.2 model with enhanced capabilities (1.75 input pricing, 14 output pricing)

app/autonomous.py

@@ -108,6 +108,12 @@ async def schedule_agent_autonomous_tasks():
 
                 try:
                     # Schedule new job based on minutes or cron
+                    # Default has_memory to True if not set (backward compatibility)
+                    task_has_memory = (
+                        autonomous.has_memory
+                        if autonomous.has_memory is not None
+                        else True
+                    )
                     if autonomous.cron:
                         logger.info(
                             f"Scheduling cron task {task_id} with cron: {autonomous.cron}"
@@ -121,6 +127,7 @@ async def schedule_agent_autonomous_tasks():
                                 agent.owner,
                                 autonomous.id,
                                 autonomous.prompt,
+                                task_has_memory,
                             ],
                             replace_existing=True,
                         )
@@ -137,6 +144,7 @@ async def schedule_agent_autonomous_tasks():
                                 agent.owner,
                                 autonomous.id,
                                 autonomous.prompt,
+                                task_has_memory,
                             ],
                             minutes=autonomous.minutes,
                             replace_existing=True,

app/entrypoints/autonomous.py

@@ -2,28 +2,49 @@
 
 from epyxid import XID
 
+from intentkit.core.agent_activity import create_agent_activity
+from intentkit.core.chat import clear_thread_memory
 from intentkit.core.client import execute_agent
+from intentkit.models.agent_activity import AgentActivityCreate
 from intentkit.models.chat import AuthorType, ChatMessageCreate
 
 logger = logging.getLogger(__name__)
 
 
 async def run_autonomous_task(
-    agent_id: str, agent_owner: str, task_id: str, prompt: str
+    agent_id: str,
+    agent_owner: str,
+    task_id: str,
+    prompt: str,
+    has_memory: bool = True,
 ):
     """
     Run a specific autonomous task for an agent.
 
     Args:
         agent_id: The ID of the agent
+        agent_owner: The owner of the agent
         task_id: The ID of the autonomous task
         prompt: The autonomous prompt to execute
+        has_memory: Whether to retain conversation memory between runs.
+                   If False, clears thread memory before execution.
     """
     logger.info(f"Running autonomous task {task_id} for agent {agent_id}")
 
     try:
         # Run the autonomous action
         chat_id = f"autonomous-{task_id}"
+
+        # Clear thread memory if has_memory is False
+        if not has_memory:
+            try:
+                _ = await clear_thread_memory(agent_id, chat_id)
+                logger.debug(
+                    f"Cleared thread memory for task {task_id} (has_memory=False)"
+                )
+            except Exception as e:
+                # Log the error but continue with execution
+                logger.warning(f"Failed to clear thread memory for task {task_id}: {e}")
         message = ChatMessageCreate(
             id=str(XID()),
             agent_id=agent_id,
@@ -43,7 +64,56 @@ async def run_autonomous_task(
             f"Task {task_id} completed: " + "\n".join(str(m) for m in resp),
             extra={"aid": agent_id},
         )
+
+        # Check response and create error activity if needed
+        if not resp:
+            try:
+                activity = AgentActivityCreate(
+                    agent_id=agent_id,
+                    text="Unexpected result: empty response",
+                )
+                _ = await create_agent_activity(activity)
+            except Exception as e:
+                logger.warning(
+                    f"Failed to create error activity for task {task_id}: {e}",
+                    extra={"aid": agent_id},
+                )
+        else:
+            last_msg = resp[-1]
+            error_text = None
+
+            if last_msg.author_type == AuthorType.AGENT:
+                pass  # Success, do nothing
+            elif last_msg.author_type == AuthorType.SYSTEM:
+                error_text = f"Task execution error: {last_msg.message}"
+            else:
+                error_text = "Unexpected return error"
+
+            if error_text:
+                try:
+                    activity = AgentActivityCreate(
+                        agent_id=agent_id,
+                        text=error_text,
+                    )
+                    _ = await create_agent_activity(activity)
+                except Exception as e:
+                    logger.warning(
+                        f"Failed to create error activity for task {task_id}: {e}",
+                        extra={"aid": agent_id},
+                    )
+
     except Exception as e:
         logger.error(
             f"Error in autonomous task {task_id} for agent {agent_id}: {str(e)}"
         )
+        try:
+            activity = AgentActivityCreate(
+                agent_id=agent_id,
+                text=f"Autonomous task exception: {str(e)}",
+            )
+            _ = await create_agent_activity(activity)
+        except Exception as activity_error:
+            logger.warning(
+                f"Failed to create exception activity for task {task_id}: {activity_error}",
+                extra={"aid": agent_id},
+            )

intentkit/models/agent.py

@@ -121,6 +121,16 @@ class AgentAutonomous(BaseModel):
             },
         ),
     ]
+    has_memory: Annotated[
+        bool | None,
+        PydanticField(
+            default=True,
+            description="Whether to retain conversation memory between autonomous runs. If False, thread memory is cleared before each run.",
+            json_schema_extra={
+                "x-group": "autonomous",
+            },
+        ),
+    ]
 
     @field_validator("id")
     @classmethod

intentkit/models/agent_schema.json

@@ -314,6 +314,13 @@
             "description": "Turn automation on/off",
             "default": false,
             "x-group": "autonomous"
+          },
+          "has_memory": {
+            "title": "Has Memory",
+            "type": "boolean",
+            "description": "Whether to retain conversation memory between autonomous runs. If disabled, thread memory is cleared before each run.",
+            "default": true,
+            "x-group": "autonomous"
           }
         },
         "required": [

intentkit/skills/system/add_autonomous_task.py

@@ -26,6 +26,10 @@ class AddAutonomousTaskInput(BaseModel):
         description="Cron expression for scheduling operations, mutually exclusive with minutes",
     )
     prompt: str = Field(description="Special prompt used during autonomous operation")
+    has_memory: bool | None = Field(
+        default=True,
+        description="Whether to retain conversation memory between autonomous runs. If False, thread memory is cleared before each run.",
+    )
 
 
 class AddAutonomousTaskOutput(BaseModel):
@@ -57,6 +61,7 @@ async def _arun(
         minutes: int | None = None,
         cron: str | None = None,
         prompt: str = "",
+        has_memory: bool | None = True,
         **kwargs,
     ) -> AddAutonomousTaskOutput:
         """Add an autonomous task to the agent.
@@ -82,6 +87,7 @@ async def _arun(
             cron=cron,
             prompt=prompt,
             enabled=True,
+            has_memory=has_memory,
         )
 
         created_task = await agent.add_autonomous_task(task)

intentkit/skills/system/edit_autonomous_task.py

@@ -34,6 +34,10 @@ class EditAutonomousTaskInput(BaseModel):
     enabled: bool | None = Field(
         default=None, description="Whether the autonomous task is enabled"
     )
+    has_memory: bool | None = Field(
+        default=None,
+        description="Whether to retain conversation memory between autonomous runs. If False, thread memory is cleared before each run.",
+    )
 
 
 class EditAutonomousTaskOutput(BaseModel):
@@ -65,6 +69,7 @@ async def _arun(
         cron: str | None = None,
         prompt: str | None = None,
         enabled: bool | None = None,
+        has_memory: bool | None = None,
         **kwargs,
     ) -> EditAutonomousTaskOutput:
         """Edit an autonomous task for the agent.
@@ -77,6 +82,7 @@ async def _arun(
             cron: Cron expression (mutually exclusive with minutes)
             prompt: Special prompt for autonomous operation
             enabled: Whether the task is enabled
+            has_memory: Whether to retain memory between runs
             config: Runtime configuration containing agent context
 
         Returns:
@@ -104,6 +110,8 @@ async def _arun(
             task_updates["prompt"] = prompt
         if enabled is not None:
             task_updates["enabled"] = enabled
+        if has_memory is not None:
+            task_updates["has_memory"] = has_memory
 
         updated_task = await agent.update_autonomous_task(task_id, task_updates)