Commit 579b07bb authored by Christopher Bremner's avatar Christopher Bremner Committed by oroulet

Ignore errors during subscription deletion

parent 085b00e4
...@@ -66,7 +66,11 @@ class SubscriptionService: ...@@ -66,7 +66,11 @@ class SubscriptionService:
else: else:
existing_subs.append(sub) existing_subs.append(sub)
res.append(ua.StatusCode()) res.append(ua.StatusCode())
await asyncio.gather(*[sub.stop() for sub in existing_subs]) exceptions = await asyncio.gather(
*[sub.stop() for sub in existing_subs], return_exceptions=True
)
for exc in exceptions:
self.logger.warning("Exception while stopping subscription", exc_info=exc)
return res return res
def publish(self, acks: Iterable[ua.SubscriptionAcknowledgement]): def publish(self, acks: Iterable[ua.SubscriptionAcknowledgement]):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment