Fix message type for local job assignment

- Use 'analyze_request' instead of 'analysis_request'
- Match the expected message type in worker processes
parent fb38da16
...@@ -603,8 +603,9 @@ class ClusterMaster: ...@@ -603,8 +603,9 @@ class ClusterMaster:
backend_comm.connect() backend_comm.connect()
# Send job to backend # Send job to backend
msg_type = 'analyze_request' if process_type == 'analysis' else 'train_request'
job_message = Message( job_message = Message(
msg_type=f'{process_type}_request', msg_type=msg_type,
msg_id=job_id, msg_id=job_id,
data=job_data data=job_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