trim comments to the load-bearing lines

Author: ayaangazali

swarms/structs/conversation.py

@@ -26,8 +26,7 @@
 from swarms.utils.generate_id import generate_id
 
 
-# Joins messages in the rendered history. Truncation measures each message
-# together with this separator, so the two must stay in sync.
+# Truncation measures each message with this separator, so keep them in sync.
 MESSAGE_SEPARATOR = "\n\n"
 
 
@@ -1565,11 +1564,8 @@ def _dynamic_auto_chunking_worker(self):
         if not messages:
             return ""
 
-        # Keep whole messages, newest first, while they fit. Each message is
-        # measured with the separator that will FOLLOW it, which the newest
-        # kept message never has. Measured that way the chunks concatenate to
-        # exactly the joined result, so — since splitting a string can only
-        # hold or raise its token count — the running total is an upper bound
+        # Whole messages, newest first. Each is measured with the separator
+        # that follows it, so the running total is an upper bound on the join
         # and the result cannot exceed context_length.
         budget = self.context_length
         kept = 0
@@ -1589,8 +1585,7 @@ def _dynamic_auto_chunking_worker(self):
             kept += 1
 
         if kept == 0:
-            # The newest message alone overflows the window, so there is no
-            # boundary to cut on — fall back to trimming inside it.
+            # The newest message alone overflows: no boundary to cut on.
             return self._truncate_to_context_length(messages[-1])
 
         return MESSAGE_SEPARATOR.join(

tests/structs/test_conversation.py

@@ -937,8 +937,7 @@ def test_dynamic_chunking_keeps_whole_messages():
     conv = _overflowing_conversation(messages=60)
     result = conv.return_history_as_string()
 
-    # time_enabled prefixes every complete message with its [timestamp],
-    # so a fragment at the front means the cut landed mid-message.
+    # Every complete message starts with its [timestamp] under time_enabled.
     for line in result.split("\n\n"):
         assert line.startswith("[")
 
@@ -967,8 +966,7 @@ def recording(text, *args, **kwargs):
     _overflowing_conversation(messages=240).return_history_as_string()
     large = sum(tokenized)
 
-    # An 8x longer transcript trims into the same size window, so the
-    # characters tokenized should stay flat rather than scale with it.
+    # 8x the transcript, same window: tokenized characters should stay flat.
     assert large < small * 2