Add more debug logging to worker loop to check if worker is receiving messages

parent f460a275
...@@ -250,7 +250,8 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id=None): ...@@ -250,7 +250,8 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id=None):
def worker_process(backend_type: str): def worker_process(backend_type: str):
"""Main worker process.""" """Main worker process."""
print(f"Starting Analysis Worker for {backend_type}...") print(f"DEBUG: Starting Analysis Worker for {backend_type}...")
print(f"DEBUG: Worker PID: {os.getpid()}")
# Workers always use Unix sockets for interprocess communication # Workers always use Unix sockets for interprocess communication
from .compat import get_socket_path from .compat import get_socket_path
...@@ -265,7 +266,9 @@ def worker_process(backend_type: str): ...@@ -265,7 +266,9 @@ def worker_process(backend_type: str):
while True: while True:
try: try:
print(f"DEBUG: Worker {os.getpid()} waiting for message...")
message = comm.receive_message() message = comm.receive_message()
print(f"DEBUG: Worker {os.getpid()} received message: {message}")
if message and message.msg_type == 'analyze_request': if message and message.msg_type == 'analyze_request':
print(f"DEBUG: Worker received analyze_request: {message.msg_id}") print(f"DEBUG: Worker received analyze_request: {message.msg_id}")
data = message.data data = message.data
......
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