add consumer config with start time

didx-xyz · Oct 24, 2024 · 1b6c7bb · 1b6c7bb
1 parent 3dff54f
commit 1b6c7bb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/waypoint/services/nats_service.py b/waypoint/services/nats_service.py
@@ -54,6 +54,10 @@ async def _subscribe(
 
             # Format the time in the required format
             start_time = time_30_secs_ago.strftime("%Y-%m-%dT%H:%M:%S.%f")[:-3] + "Z"
+            config = ConsumerConfig(
+                deliver_policy=DeliverPolicy.BY_START_TIME,
+                opt_start_time=start_time,
+            )
 
             return subscription