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
Below is a snippet of code I'm running to handle multiple subscriptions in program. I've got this to work successfully on my x86 machine but when I move to an arm64
nc=awaitnats.connect(...)
js=nc.jetstream()
consumers= []
forsubinsubscription:
consumer=awaitjs.pull_subscribe(subject=subject, stream=stream, durable=durable_name)
logger.debug(f"Consumer info {awaitconsumer.consumer_info()}") # returns expectedconsumers.append(consumer)
# laterwhileTrue:
forconsumerinconsumers:
logger.debug(f"Consumer info {awaitconsumer.consumer_info()}") # 404 herefetched=awaitconsumer.fetch(1) # times out hereforminfetched:
awaitm.ack()
Expected behavior
Consumers to not lose connection with nats when passed
Observed behavior
Below is a snippet of code I'm running to handle multiple subscriptions in program. I've got this to work successfully on my x86 machine but when I move to an arm64
Expected behavior
Consumers to not lose connection with nats when passed
Server and client version
cli: v0.1.4
server: nats:2.10.9-alpine
Host environment
ubuntu 22.04
nats-py==2.9.0
aarch64
k3s 1.28
python 3.10
Steps to reproduce
No response
The text was updated successfully, but these errors were encountered: