Fix cluster master access

- Update global cluster_master instance for cross-module access
- Allows queue manager to access active jobs for cancellation
- Enables proper job_id logging in cancellation messages
parent 44af5090
......@@ -1459,6 +1459,11 @@ def start_cluster_master(host: str = '0.0.0.0', port: int = 5003, shared_dir: st
master.shared_dir = shared_dir
master.weight = weight
master.weight_explicit = weight_explicit
# Update the global instance for access from other modules
global cluster_master
cluster_master = master
asyncio.run(master.start())
......
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