(self)
| 578 | ) |
| 579 | |
| 580 | def update_watches(self): |
| 581 | try: |
| 582 | self._update_watches() |
| 583 | except Exception as ex: |
| 584 | # If the service is still available, raise the original exception. |
| 585 | if self.check_server_status(ex): |
| 586 | raise |
| 587 | |
| 588 | def _check_subscription(self, sub): |
| 589 | subscription = self.client.getSubscription(sub) |