Add debug logs to backend.py for worker_sockets debugging

parent 96fe679d
...@@ -59,6 +59,8 @@ def handle_web_message(message: Message, client_sock=None) -> Message: ...@@ -59,6 +59,8 @@ def handle_web_message(message: Message, client_sock=None) -> Message:
backend = get_analysis_backend() backend = get_analysis_backend()
worker_key = f'analysis_{backend}' worker_key = f'analysis_{backend}'
print(f"Backend forwarding analyze_request {message.msg_id} to worker {worker_key}") print(f"Backend forwarding analyze_request {message.msg_id} to worker {worker_key}")
print(f"DEBUG: backend = {backend}, worker_key = {worker_key}")
print(f"DEBUG: Checking worker_sockets for {worker_key}, keys: {list(worker_sockets.keys())}")
if worker_key in worker_sockets: if worker_key in worker_sockets:
# Forward to local worker # Forward to local worker
import json import json
...@@ -139,6 +141,7 @@ def handle_worker_message(message: Message, client_sock) -> None: ...@@ -139,6 +141,7 @@ def handle_worker_message(message: Message, client_sock) -> None:
if worker_type: if worker_type:
worker_sockets[worker_type] = client_sock worker_sockets[worker_type] = client_sock
print(f"Worker {worker_type} registered") print(f"Worker {worker_type} registered")
print(f"DEBUG: worker_sockets keys after register: {list(worker_sockets.keys())}")
# Notify cluster master that a worker has registered # Notify cluster master that a worker has registered
try: try:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment