diff options
| author | Kevin O'Connor <kevin@koconnor.net> | 2021-09-26 12:24:40 -0400 |
|---|---|---|
| committer | Kevin O'Connor <kevin@koconnor.net> | 2021-09-26 12:24:40 -0400 |
| commit | c543b00aa60cc7e3c3d04edd126d2bc1984cfabf (patch) | |
| tree | 74cce4e8ada9b54151aebd50c46c28fb8fb991df /scripts/motan/data_logger.py | |
| parent | 1eecd412ef1bbf36d838987efed9391c02e08638 (diff) | |
| download | kutter-c543b00aa60cc7e3c3d04edd126d2bc1984cfabf.tar.gz kutter-c543b00aa60cc7e3c3d04edd126d2bc1984cfabf.tar.xz kutter-c543b00aa60cc7e3c3d04edd126d2bc1984cfabf.zip | |
motan: Improve handling of errors during data subscriptions
Signed-off-by: Kevin O'Connor <kevin@koconnor.net>
Diffstat (limited to 'scripts/motan/data_logger.py')
| -rwxr-xr-x | scripts/motan/data_logger.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/scripts/motan/data_logger.py b/scripts/motan/data_logger.py index cd64e465..591644c1 100755 --- a/scripts/motan/data_logger.py +++ b/scripts/motan/data_logger.py @@ -159,6 +159,10 @@ class DataLogger: {"sensor": aname}) def handle_dump(self, msg, raw_msg): msg_id = msg["id"] + if "result" not in msg: + self.error("Unable to subscribe to '%s': %s" + % (msg_id, msg.get("error", {}).get("message", ""))) + return self.db.setdefault("subscriptions", {})[msg_id] = msg["result"] def flush_index(self): self.db['file_position'] = self.logger.flush() |