Revision 59303563 lib/jqueue.py
b/lib/jqueue.py | ||
---|---|---|
522 | 522 |
|
523 | 523 |
# Get initial list of nodes |
524 | 524 |
self._nodes = dict((n.name, n.primary_ip) |
525 |
for n in self.context.cfg.GetAllNodesInfo().values()) |
|
525 |
for n in self.context.cfg.GetAllNodesInfo().values() |
|
526 |
if n.master_candidate) |
|
526 | 527 |
|
527 | 528 |
# Remove master node |
528 | 529 |
try: |
... | ... | |
596 | 597 |
# Clean queue directory on added node |
597 | 598 |
rpc.RpcRunner.call_jobqueue_purge(node_name) |
598 | 599 |
|
600 |
if not node.master_candidate: |
|
601 |
# remove if existing, ignoring errors |
|
602 |
self._nodes.pop(node_name, None) |
|
603 |
# and skip the replication of the job ids |
|
604 |
return |
|
605 |
|
|
599 | 606 |
# Upload the whole queue excluding archived jobs |
600 | 607 |
files = [self._GetJobPath(job_id) for job_id in self._GetJobIDsUnlocked()] |
601 | 608 |
|
Also available in: Unified diff