NATS JetStream is Timing out when calling stream_info(STREAM_NAME)

3.7k views Asked by At

raise errors.TimeoutError nats.errors.TimeoutError: nats: timeout

if self.nc.is_connected:
            log.info(f"NATS client successfully connected to {SERVERS}")
            # Create jetstream context and check if stream exists
            self.nc = self.nc.jetstream()
            log.info("Created contextual JetStream object!")
            try:
                # Check if the JetStream exists [Client has already created JetStream and subject associations]
                acc_info = await self.nc.account_info()
                info = await self.nc.stream_info(STREAM_NAME)

The code is erroring out when using the JetStream context prior to adding a stream. Upon deletion of a stream, and calling stream_info() after, the NotFoundError is returned and handled. Why does the returned exception change so suddenly? Any help is greatly appreciated.

File "/usr/local/lib/python3.9/site-packages/nats/js/manager.py", line 65, in stream_info
    resp = await self._api_request(
  File "/usr/local/lib/python3.9/site-packages/nats/js/manager.py", line 158, in _api_request
    msg = await self._nc.request(req_subject, req, timeout=timeout)
  File "/usr/local/lib/python3.9/site-packages/nats/aio/client.py", line 899, in request
    msg = await self._request_new_style(
  File "/usr/local/lib/python3.9/site-packages/nats/aio/client.py", line 939, in _request_new_style
    raise errors.TimeoutError
nats.errors.TimeoutError: nats: timeout
1

There are 1 answers

1
JNM On
  • Is your nats-server configured to enable JetStream functionality (i.e. either in it's config file or passing the -js command line argument)?

  • Is your account allowed to use JetStream? nats account info will tell you.