We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0e69359 commit 00d5b18Copy full SHA for 00d5b18
internal_filesystem/lib/websocket.py
@@ -37,13 +37,15 @@ class WebSocketTimeoutException(WebSocketException):
37
_callback_queue = ucollections.deque((), 100) # Empty tuple, maxlen=100
38
39
def _run_callback(callback, *args):
40
+ if not callback:
41
+ print("_run_callback: skipping None callback")
42
+ return
43
"""Add callback to queue for execution."""
44
try:
45
_callback_queue.append((callback, args))
46
_log_debug(f"Queued callback {callback}, args={args}, queue size: {len(_callback_queue)}")
- #if callback:
- # print("Doing callback directly:")
- # callback(*args)
47
+ # print("Doing callback directly:")
48
+ # callback(*args)
49
except IndexError:
50
_log_error("ERROR: websocket.py callback queue full, dropping callback")
51
0 commit comments