Skip to content
Snippets Groups Projects

stop igwn alert client only if it is running; fixes #488

Merged Deep Chatterjee requested to merge deep.chatterjee/gwcelery:fix-488 into main
1 file
+ 3
2
Compare changes
  • Side-by-side
  • Inline
@@ -106,8 +106,9 @@ class Receiver(IGWNAlertBootStep):
def stop(self, consumer):
super().stop(consumer)
self._client.running = False
self._client.stream_obj._consumer.stop()
if self._client.running:
self._client.running = False
self._client.stream_obj._consumer.stop()
self.thread.join()
def info(self, consumer):
Loading