fix deprecated utcnow usage

Author: NotAWiz4rd

agent/base_agent.py

@@ -57,7 +57,7 @@ def __init__(self, agent_name: str, llm_client, team_mode: bool, turn_delay=0):
         self.max_consecutive_tools = 20
         self.group_chat_messages = []
         self.last_logged_index = 0  # Last index of the group chat messages that were logged
-        self.last_log_time = datetime.datetime.utcnow().isoformat()  # Last time a log was sent
+        self.last_log_time = datetime.datetime.now(datetime.timezone.utc).isoformat()  # Last time a log was sent
         self.turn_delay = turn_delay
 
         self.name = agent_name
@@ -74,7 +74,7 @@ def check_and_send_work_log(self, conversation):
             # Check if there are new messages since the last log
             new_messages = conversation[self.last_logged_index:]
             first_timestamp = self.last_log_time
-            last_timestamp = datetime.datetime.utcnow().isoformat()
+            last_timestamp = datetime.datetime.now(datetime.timezone.utc).isoformat()
             success = send_work_log(self.name, new_messages, first_timestamp, last_timestamp)
             if success:
                 self.steps_since_last_log = 0

group_chat/group_chat.py

@@ -1,6 +1,6 @@
 import os
 import threading
-from datetime import datetime
+from datetime import datetime, timezone
 from typing import List
 
 from fastapi import FastAPI
@@ -52,7 +52,7 @@ def load_messages():
         # Add an initial message from the "supervisor"
         initial_message = StoredMessage(
             username="supervisor",
-            timestamp=datetime.utcnow().isoformat(),
+            timestamp=datetime.now(timezone.utc).isoformat(),
             message=os.getenv("INITIAL_GROUP_CHAT_MESSAGE", INITIAL_MESSAGE),
         )
         messages.append(initial_message)
@@ -96,7 +96,7 @@ async def send_message(msg: Message):
     global message_count
     message_count += 1
 
-    now = datetime.utcnow().isoformat()
+    now = datetime.now(timezone.utc).isoformat()
     stored = StoredMessage(username=msg.username, timestamp=now, message=msg.message)
     with lock:
         print(f"Received message by {msg.username}: {msg.message}")

group_work_log/group_work_log.py

@@ -1,6 +1,6 @@
 import threading
 from contextlib import asynccontextmanager
-from datetime import datetime
+from datetime import datetime, timezone
 import os
 from typing import List, Optional, Dict, Any
 
@@ -80,7 +80,7 @@ def read_previous_summaries():
                     if len(timespan_parts) >= 2:
                         current_timestamp = timespan_parts[1].strip()
                     else:
-                        current_timestamp = datetime.utcnow().isoformat()
+                        current_timestamp = datetime.now(timezone.utc).isoformat()
 
                 else:
                     # Continue building the current summary
@@ -189,7 +189,7 @@ async def submit_worklog(request: WorklogRequest):
     if not messages:
         raise HTTPException(status_code=400, detail="Empty messages provided")
 
-    now = datetime.utcnow().isoformat()
+    now = datetime.now(timezone.utc).isoformat()
     response = {"status": "ok"}
 
     with lock:

tests/unit/group_work_log/test_group_work_log.py

@@ -107,10 +107,10 @@ def test_returns_empty_list_initially(self, client):
     def test_after_timestamp_filters_older_entries(self, client):
         client.post("/submit-worklog", json=_WORKLOG_PAYLOAD)
         import time
-        from datetime import datetime
+        from datetime import datetime, timezone
         time.sleep(0.01)
         # Always include microseconds to satisfy server-side strptime validation
-        cutoff = datetime.utcnow().strftime("%Y-%m-%dT%H:%M:%S.%f")
+        cutoff = datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%S.%f")
         time.sleep(0.01)
         client.post("/submit-worklog", json={**_WORKLOG_PAYLOAD, "agent_name": "AgentB"})
         r = client.get(f"/summaries?after_timestamp={cutoff}")