enhance: More robut time setting and skip empty message for ChatAgent (#2582)

Author: Wendong-Fan

camel/agents/chat_agent.py

@@ -19,7 +19,6 @@
 import threading
 import uuid
 from collections import defaultdict
-from datetime import datetime
 from pathlib import Path
 from typing import (
     TYPE_CHECKING,
@@ -509,15 +508,15 @@ def update_memory(
                 memory record. If None, current timestamp will be used.
                 (default: :obj:`None`)
         """
-        from datetime import timezone
+        import time
 
         self.memory.write_record(
             MemoryRecord(
                 message=message,
                 role_at_backend=role,
                 timestamp=timestamp
                 if timestamp is not None
-                else datetime.now(timezone.utc).timestamp(),
+                else time.time_ns() / 1_000_000_000,  # Nanosecond precision
                 agent_id=self.agent_id,
             )
         )
@@ -1331,6 +1330,13 @@ def _handle_batch_response(
         """
         output_messages: List[BaseMessage] = []
         for choice in response.choices:
+            # Skip messages with no meaningful content
+            if (
+                choice.message.content is None
+                or choice.message.content.strip() == ""
+            ) and not choice.message.tool_calls:
+                continue
+
             meta_dict = {}
             if logprobs_info := handle_logprobs(choice):
                 meta_dict["logprobs_info"] = logprobs_info
@@ -1623,17 +1629,24 @@ def _record_tool_calling(
             tool_call_id=tool_call_id,
         )
 
-        # Use slightly different timestamps to ensure correct ordering
+        # Use precise timestamps to ensure correct ordering
         # This ensures the assistant message (tool call) always appears before
         # the function message (tool result) in the conversation context
-        current_time = datetime.now().timestamp()
+        # Use time.time_ns() for nanosecond precision to avoid collisions
+        import time
+
+        current_time_ns = time.time_ns()
+        base_timestamp = current_time_ns / 1_000_000_000  # Convert to seconds
+
         self.update_memory(
-            assist_msg, OpenAIBackendRole.ASSISTANT, timestamp=current_time
+            assist_msg, OpenAIBackendRole.ASSISTANT, timestamp=base_timestamp
         )
+
+        # Add minimal increment to ensure function message comes after
         self.update_memory(
             func_msg,
             OpenAIBackendRole.FUNCTION,
-            timestamp=current_time + 0.001,
+            timestamp=base_timestamp + 1e-9,
         )
 
         # Record information about this tool call

camel/memories/records.py

@@ -15,8 +15,8 @@
 # Enables postponed evaluation of annotations (for string-based type hints)
 from __future__ import annotations
 
+import time
 from dataclasses import asdict
-from datetime import datetime, timezone
 from typing import Any, ClassVar, Dict
 from uuid import UUID, uuid4
 
@@ -53,7 +53,8 @@ class MemoryRecord(BaseModel):
     uuid: UUID = Field(default_factory=uuid4)
     extra_info: Dict[str, str] = Field(default_factory=dict)
     timestamp: float = Field(
-        default_factory=lambda: datetime.now(timezone.utc).timestamp()
+        default_factory=lambda: time.time_ns()
+        / 1_000_000_000  # Nanosecond precision
     )
     agent_id: str = Field(default="")
 
@@ -109,5 +110,6 @@ class ContextRecord(BaseModel):
     memory_record: MemoryRecord
     score: float
     timestamp: float = Field(
-        default_factory=lambda: datetime.now(timezone.utc).timestamp()
+        default_factory=lambda: time.time_ns()
+        / 1_000_000_000  # Nanosecond precision
     )