aboutsummaryrefslogtreecommitdiff
path: root/worker.py
diff options
context:
space:
mode:
Diffstat (limited to 'worker.py')
-rw-r--r--worker.py9
1 files changed, 1 insertions, 8 deletions
diff --git a/worker.py b/worker.py
index c3dc9d6..9f6086b 100644
--- a/worker.py
+++ b/worker.py
@@ -122,7 +122,6 @@ class MonitorTask(Thread):
Parameters
----------
- None
Returns
-------
@@ -161,7 +160,6 @@ class MonitorTask(Thread):
Parameters
----------
- None
Returns
-------
@@ -340,7 +338,6 @@ class ServerWorker(Thread):
# except Exception as exc:
# logger.error("Sending camera metadata update to websocket failed: %r", exc)
- return False
def handle_video_message(self, msg: list) -> None:
logger.debug("Received video message with data only.")
@@ -352,7 +349,7 @@ class ServerWorker(Thread):
self.video_threads[client_id][camera_id].queue.put(content[0])
# Send only [client_id, camera_id, jpeg_bytes] to the webserver:
- # zmq subsciber can subscribe to a topic defined by the first
+ # zmq subscriber can subscribe to a topic defined by the first
# part of the multipart message, so in order to allow for a
# per camera subscription, we need to join client_id and camera_id
topic = b':'.join([client_id, camera_id])
@@ -368,7 +365,6 @@ class ServerWorker(Thread):
Parameters
----------
- None
Returns
-------
@@ -459,7 +455,6 @@ class ServerWorker(Thread):
Parameters
----------
- None
Returns
-------
@@ -524,7 +519,6 @@ class VideoWorker(Thread):
Parameters
----------
- None
Returns
-------
@@ -539,7 +533,6 @@ class VideoWorker(Thread):
Parameters
----------
- None
Returns
-------