From 058565726bc381837301f266bcc11740679be6ba Mon Sep 17 00:00:00 2001 From: Sabiha Khan Date: Mon, 6 Jul 2026 09:28:48 +0530 Subject: [PATCH] fi: timestamp precision to millisec instead of micro --- api/services/pipecat/in_memory_buffers.py | 2 +- api/tests/test_realtime_feedback_observer.py | 9 +++++++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/api/services/pipecat/in_memory_buffers.py b/api/services/pipecat/in_memory_buffers.py index 72ee89bc..1179e4a8 100644 --- a/api/services/pipecat/in_memory_buffers.py +++ b/api/services/pipecat/in_memory_buffers.py @@ -129,7 +129,7 @@ class InMemoryLogsBuffer: @staticmethod def _now_iso() -> str: - return datetime.now(UTC).isoformat() + return datetime.now(UTC).isoformat(timespec="milliseconds") def mark_user_started_speaking(self): """Record when the user started speaking for the current turn.""" diff --git a/api/tests/test_realtime_feedback_observer.py b/api/tests/test_realtime_feedback_observer.py index edf83207..909b8f92 100644 --- a/api/tests/test_realtime_feedback_observer.py +++ b/api/tests/test_realtime_feedback_observer.py @@ -1,4 +1,5 @@ from types import SimpleNamespace +import re import pytest from pipecat.frames.frames import ( @@ -200,6 +201,14 @@ async def test_observer_attaches_backend_speaking_intervals_to_logged_transcript ] assert user_event["payload"]["timestamp"] != "aggregator-user-start" + assert re.match( + r"^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}\.\d{3}\+00:00$", + user_event["payload"]["timestamp"], + ) assert user_event["payload"]["end_timestamp"] assert bot_event["payload"]["timestamp"] != "aggregator-bot-start" + assert re.match( + r"^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}\.\d{3}\+00:00$", + bot_event["payload"]["timestamp"], + ) assert bot_event["payload"]["end_timestamp"]