Add debug prints to worker connection and registration

- Show when worker connects to backend
- Show when worker registers
- Help debug why jobs aren't being received
parent a2e19c42
......@@ -241,10 +241,12 @@ def worker_process(backend_type: str):
from .compat import get_socket_path
comm = SocketCommunicator(socket_path=get_socket_path('worker'), comm_type='unix')
comm.connect()
print(f"Analysis Worker connected to backend")
# Register with backend
register_msg = Message('register', 'register', {'type': f'analysis_{backend_type}'})
comm.send_message(register_msg)
print(f"Analysis Worker registered as analysis_{backend_type}")
while True:
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