Delete Observations
delete_observationsRemove specific observations from entities in the knowledge graph to maintain accurate memory by deleting outdated or incorrect information.
Instructions
Delete specific observations from entities in the knowledge graph
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| deletions | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| message | Yes | ||
| success | Yes |
Implementation Reference
- The actual database operation implementation for deleting observations from an entity.
async def delete_observations( self, deletions: List[Dict[str, Any]], batch_size: int = 1000 ) -> None: """Remove specific observations from entities using batch processing.""" async with self.pool.get_connection() as conn: async with self.pool.transaction(conn): for i in range(0, len(deletions), batch_size): batch = deletions[i:i + batch_size] for deletion in batch: entity_name = sanitize_input(deletion["entityName"]) to_delete = set(deletion["observations"]) cursor = await conn.execute( "SELECT observations FROM entities WHERE name = ?", (entity_name,) ) result = await cursor.fetchone() if result: current_obs = result['observations'].split(',') if result['observations'] else [] updated_obs = [obs for obs in current_obs if obs not in to_delete] await conn.execute( "UPDATE entities SET observations = ? WHERE name = ?", (','.join(updated_obs), entity_name) )