You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
importasyncioimportnatsasyncdefmain():
asyncdeferror_handler(e):
print("Error:", e, type(e))
nc=awaitnats.connect(error_cb=error_handler)
js=nc.jetstream()
# Create pull based consumerpsub=awaitjs.pull_subscribe("foobar", "psub")
awaitnc.close()
if__name__=="__main__":
asyncio.run(main())
Given the capability you are leveraging, describe your expectation?
A self-descriptive helpful error message
Given the expectation, what is the defect you are observing?
asyncio.run(main())
File "/opt/homebrew/Cellar/python@3.10/3.10.12_1/Frameworks/Python.framework/Versions/3.10/lib/python3.10/asyncio/runners.py", line 44, in run
return loop.run_until_complete(main)
File "/opt/homebrew/Cellar/python@3.10/3.10.12_1/Frameworks/Python.framework/Versions/3.10/lib/python3.10/asyncio/base_events.py", line 649, in run_until_complete
return future.result()
File "/Users/tekumara/code/nats-demo/src/demo/durable_watch.py", line 38, in main
psub = await js.pull_subscribe("foobar", "psub")
File "/Users/tekumara/code/nats-demo/.venv/lib/python3.10/site-packages/nats/js/client.py", line 410, in pull_subscribe
stream = await self._jsm.find_stream_name_by_subject(subject)
File "/Users/tekumara/code/nats-demo/.venv/lib/python3.10/site-packages/nats/js/manager.py", line 65, in find_stream_name_by_subject
return info['streams'][0]
TypeError: 'NoneType' object is not subscriptable
The text was updated successfully, but these errors were encountered:
What version were you using?
2.4.0
What environment was the server running in?
n/a
Is this defect reproducible?
Given the capability you are leveraging, describe your expectation?
A self-descriptive helpful error message
Given the expectation, what is the defect you are observing?
The text was updated successfully, but these errors were encountered: