add config to subscription

didx-xyz · Oct 24, 2024 · 4505d15 · 4505d15
1 parent 1b6c7bb
commit 4505d15
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/waypoint/services/nats_service.py b/waypoint/services/nats_service.py
@@ -58,6 +58,9 @@ async def _subscribe(
                 deliver_policy=DeliverPolicy.BY_START_TIME,
                 opt_start_time=start_time,
             )
+            subscription = await self.js_context.pull_subscribe(
+                config=config, **subscribe_kwargs
+            )
 
             return subscription