remove is instance check

didx-xyz · Feb 21, 2025 · 0e66862 · 0e66862
1 parent ea0a902
commit 0e66862
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/waypoint/services/nats_service.py b/waypoint/services/nats_service.py
@@ -97,13 +97,9 @@ async def pull_subscribe():
                     config=config, **subscribe_kwargs
                 )
 
-                consumer_info = await subscription.consumer_info()
-                if isinstance(consumer_info, ConsumerInfo):
-                    bound_logger.trace(
-                        "Consumer is ready {}, {}",
-                        consumer_info.name,
-                        consumer_info.stream_name,
-                    )
+                # Get consumer info to verify that the subscription was successful
+                # TODO test if this is necessary
+                await subscription.consumer_info()
 
                 bound_logger.debug("Successfully subscribed to JetStream")
                 return subscription