From 6cfa25c24036d8ab97433cf7a8c43d427f9800a8 Mon Sep 17 00:00:00 2001
From: johannes walcher <johannes.walcher@stusta.de>
Date: Thu, 3 May 2018 17:17:13 +0200
Subject: [PATCH] fixed linter warnings
---
rupprecht/rupprecht.py | 12 ++++--------
1 file changed, 4 insertions(+), 8 deletions(-)
diff --git a/rupprecht/rupprecht.py b/rupprecht/rupprecht.py
index 5d21209..8ab1209 100644
--- a/rupprecht/rupprecht.py
+++ b/rupprecht/rupprecht.py
@@ -9,7 +9,7 @@ from hauptbahnhof import Hauptbahnhof
from . import rcswitch
-class RupprechtError:
+class RupprechtError(Exception):
pass
class RupprechtCommandError(RupprechtError):
@@ -133,11 +133,7 @@ class RupprechtInterface:
self.response_event.clear()
# Await, if there was another message in the pipeline that has not
# yet been processed
- if not force:
- while self.response_pending:
- print("before sending '{}' we need a response for '{}'".format(msg, self.last_command))
- await self.response_event.wait()
- self.response_event.clear()
+
print("Sending", msg)
# If the queue has been processed by somebody else in the meantime
if not self._queue:
@@ -179,8 +175,8 @@ class RupprechtInterface:
print("received \033[03m{}\033[0m".format(msg))
if str.startswith(msg, "BUTTON"):
try:
- self.buttons = json.loads(msg[len("BUTTON"):])
- asyncio.gather(*[b(self.buttons) for b in self.button_callbacks], loop=self.loop)
+ buttons = json.loads(msg[len("BUTTON"):])
+ asyncio.gather(*[b(buttons) for b in self.button_callbacks], loop=self.loop)
except json.decoder.JSONDecodeError:
print("Invalid json received:", msg)
elif msg == "READY" and not self.ready:
--
GitLab