diff --git a/waypoint/services/nats_service.py b/waypoint/services/nats_service.py index 260c26705..6b3650c5e 100644 --- a/waypoint/services/nats_service.py +++ b/waypoint/services/nats_service.py @@ -42,7 +42,7 @@ async def _subscribe( # Get the current time in UTC current_time = datetime.now(timezone.utc) - # Subtract 30 seconds + # Subtract look_back time from the current time look_back_time = current_time - timedelta(seconds=look_back) # Format the time in the required format