|
|
@ -171,7 +171,7 @@ def jsonrpc_handler(end_event: threading.Event) -> None: |
|
|
|
try: |
|
|
|
try: |
|
|
|
data = recv_queue.get(timeout=1) |
|
|
|
data = recv_queue.get(timeout=1) |
|
|
|
if "method" in data: |
|
|
|
if "method" in data: |
|
|
|
cloudlog.debug(f"athena.jsonrpc_handler.call_method {data}") |
|
|
|
cloudlog.event("athena.jsonrpc_handler.call_method", data=data) |
|
|
|
response = JSONRPCResponseManager.handle(data, dispatcher) |
|
|
|
response = JSONRPCResponseManager.handle(data, dispatcher) |
|
|
|
send_queue.put_nowait(response.json) |
|
|
|
send_queue.put_nowait(response.json) |
|
|
|
elif "id" in data and ("result" in data or "error" in data): |
|
|
|
elif "id" in data and ("result" in data or "error" in data): |
|
|
|