Remove cancel job logging

- Silent job cancellation operations
- No logging for cancel commands sent to workers
- Clean operation without console noise
parent 7585f948
...@@ -647,8 +647,6 @@ class ClusterMaster: ...@@ -647,8 +647,6 @@ class ClusterMaster:
client_id = job_info['client_id'] client_id = job_info['client_id']
worker_key = job_info['worker_key'] worker_key = job_info['worker_key']
print(f"Cancelling job {job_id} on worker {worker_key}")
if client_id == "local": if client_id == "local":
# Send cancel to local backend # Send cancel to local backend
try: try:
...@@ -664,7 +662,6 @@ class ClusterMaster: ...@@ -664,7 +662,6 @@ class ClusterMaster:
data={'job_id': job_id} data={'job_id': job_id}
) )
backend_comm.send_message(cancel_message) backend_comm.send_message(cancel_message)
print(f"Sent cancel request for job {job_id} to local backend")
except Exception as e: except Exception as e:
print(f"Failed to send cancel to local backend: {e}") print(f"Failed to send cancel to local backend: {e}")
else: else:
...@@ -675,7 +672,6 @@ class ClusterMaster: ...@@ -675,7 +672,6 @@ class ClusterMaster:
'type': 'cancel_job', 'type': 'cancel_job',
'job_id': job_id 'job_id': job_id
})) }))
print(f"Sent cancel request for job {job_id} to client {client_id}")
except Exception as e: except Exception as e:
print(f"Failed to send cancel to client {client_id}: {e}") print(f"Failed to send cancel to client {client_id}: {e}")
if client_id in self.clients: if client_id in self.clients:
......
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